fix susbcriber

Author: lawrence-forooghian

Tests/AblyLiveObjectsTests/Helpers/Subscriber.swift

@@ -44,8 +44,7 @@ final class Subscriber<each CallbackArg: Sendable>: Sendable {
                 let invocation = (repeat each arg)
                 invocations.append(invocation)
 
-                let listeners = self.listeners
-                return {
+                return { [listeners] in
                     for listener in listeners {
                         listener.callAsFunction(repeat each invocation)
                     }
@@ -76,10 +75,11 @@ final class Subscriber<each CallbackArg: Sendable>: Sendable {
         let performInvocations = mutex.withLock {
             listeners.append(.init(callback: listener))
 
-            let invocations = self.invocations
-            return {
+            return { [invocations, callbackQueue] in
                 for invocation in invocations {
-                    listener(repeat each invocation)
+                    callbackQueue.async {
+                        listener(repeat each invocation)
+                    }
                 }
             }
         }