Merge pull request #35 from spotify/expose-events-openfeature-api

Expose events openfeature api
spotify · Jul 25, 2023 · 5da99a5 · 5da99a5
2 parents 49f0314 + 6e2f6d5
commit 5da99a5
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/OpenFeature/src/main/java/dev/openfeature/sdk/OpenFeatureAPI.kt b/OpenFeature/src/main/java/dev/openfeature/sdk/OpenFeatureAPI.kt
@@ -1,8 +1,15 @@
 package dev.openfeature.sdk
 
+import dev.openfeature.sdk.events.EventHandler
+import dev.openfeature.sdk.events.OpenFeatureEvents
+import dev.openfeature.sdk.events.observe
+import kotlinx.coroutines.CoroutineDispatcher
+
+@Suppress("TooManyFunctions")
 object OpenFeatureAPI {
     private var provider: FeatureProvider? = null
     private var context: EvaluationContext? = null
+
     var hooks: List<Hook<*>> = listOf()
         private set
 
@@ -16,6 +23,10 @@ object OpenFeatureAPI {
         return provider
     }
 
+    inline fun <reified T : OpenFeatureEvents> observeEvents(dispatcher: CoroutineDispatcher) =
+        EventHandler.eventsObserver(dispatcher)
+            .observe<T>()
+
     fun clearProvider() {
         provider = null
     }

diff --git a/.../openfeature/sdk/events/EventPublisher.kt → ...ev/openfeature/sdk/events/EventHandler.kt b/.../openfeature/sdk/events/EventPublisher.kt → ...ev/openfeature/sdk/events/EventHandler.kt
@@ -73,7 +73,7 @@ class EventHandler(dispatcher: CoroutineDispatcher) : EventObserver, EventsPubli
 
         fun eventsObserver(dispatcher: CoroutineDispatcher = Dispatchers.IO): EventObserver =
             getInstance(dispatcher)
-        fun providerStatus(dispatcher: CoroutineDispatcher = Dispatchers.IO): ProviderStatus =
+        internal fun providerStatus(dispatcher: CoroutineDispatcher = Dispatchers.IO): ProviderStatus =
             getInstance(dispatcher)
         fun eventsPublisher(dispatcher: CoroutineDispatcher = Dispatchers.IO): EventsPublisher =
             getInstance(dispatcher)