Merge branch 'feature/object-subscriptions' into feature/server-provided-tombstone-serial

Author: sacOO7

live-objects/src/main/kotlin/io/ably/lib/objects/DefaultLiveObjects.kt

@@ -38,17 +38,18 @@ internal class DefaultLiveObjects(internal val channelName: String, internal val
   private val sequentialScope =
     CoroutineScope(Dispatchers.Default.limitedParallelism(1) + CoroutineName(channelName) + SupervisorJob())
 
-  /**
-   * Provides a channel-specific scope for safely executing asynchronous operations with callbacks.
-   */
-  private val callbackScope = ObjectsCallbackScope(channelName)
-
   /**
    * Event bus for handling incoming object messages sequentially.
+   * Processes messages inside [incomingObjectsHandler] job created using [sequentialScope].
    */
   private val objectsEventBus = MutableSharedFlow<ProtocolMessage>(extraBufferCapacity = UNLIMITED)
   private val incomingObjectsHandler: Job
 
+  /**
+   * Provides a channel-specific scope for safely executing asynchronous operations with callbacks.
+   */
+  private val asyncScope = ObjectsAsyncScope(channelName)
+
   init {
     incomingObjectsHandler = initializeHandlerForIncomingObjectMessages()
   }
@@ -68,7 +69,7 @@ internal class DefaultLiveObjects(internal val channelName: String, internal val
   }
 
   override fun getRootAsync(callback: Callback<LiveMap>) {
-    callbackScope.launchWithCallback(callback) { getRootAsync() }
+    asyncScope.launchWithCallback(callback) { getRootAsync() }
   }
 
   override fun createMapAsync(liveMap: LiveMap, callback: Callback<LiveMap>) {
@@ -204,6 +205,6 @@ internal class DefaultLiveObjects(internal val channelName: String, internal val
     objectsManager.dispose()
     // Don't cancel sequentialScope (needed in getRoot method), just cancel ongoing coroutines
     sequentialScope.coroutineContext.cancelChildren(disposeReason)
-    callbackScope.cancel(disposeReason) // cancel all ongoing callbacks
+    asyncScope.cancel(disposeReason) // cancel all ongoing callbacks
   }
 }

live-objects/src/main/kotlin/io/ably/lib/objects/Utils.kt

@@ -54,7 +54,7 @@ internal val String.byteSize: Int
  * Provides safe execution of suspend functions with results delivered via callbacks.
  * Supports proper error handling and cancellation during LiveObjects disposal.
  */
-internal class ObjectsCallbackScope(channelName: String) {
+internal class ObjectsAsyncScope(channelName: String) {
   private val tag = "ObjectsCallbackScope-$channelName"
 
   private val scope =