Refactoring Client for a better scope implementation

infiniticio · Sep 25, 2024 · 09be271 · 09be271
1 parent bcefe49
commit 09be271
Show file tree

Hide file tree

Showing 3 changed files with 389 additions and 288 deletions.
diff --git a/infinitic-client/src/main/kotlin/io/infinitic/clients/InfiniticClient.kt b/infinitic-client/src/main/kotlin/io/infinitic/clients/InfiniticClient.kt
@@ -80,9 +80,9 @@ class InfiniticClient(
   private var isClosed: AtomicBoolean = AtomicBoolean(false)
 
   // Scope used to asynchronously send message, and also to consumes messages
-  private val clientScope = CoroutineScope(Dispatchers.IO)
+  internal val clientScope = CoroutineScope(Dispatchers.IO)
 
-  private val dispatcher by lazy { ClientDispatcher(clientScope, consumer, producer) }
+  private val dispatcher by lazy { ClientDispatcher(clientScope, consumer, producer, logger) }
 
   override suspend fun getName() = producer.getName()