Make public API listeners @escaping

Missed this in ce8c022.

Author: lawrence-forooghian

Sources/AblyLiveObjects/Internal/DefaultLiveCounter.swift

@@ -90,15 +90,15 @@ internal final class InternalDefaultLiveCounter: Sendable {
         notYetImplemented()
     }
 
-    internal func subscribe(listener _: LiveObjectUpdateCallback<LiveCounterUpdate>) -> any SubscribeResponse {
+    internal func subscribe(listener _: @escaping LiveObjectUpdateCallback<LiveCounterUpdate>) -> any SubscribeResponse {
         notYetImplemented()
     }
 
     internal func unsubscribeAll() {
         notYetImplemented()
     }
 
-    internal func on(event _: LiveObjectLifecycleEvent, callback _: LiveObjectLifecycleEventCallback) -> any OnLiveObjectLifecycleEventResponse {
+    internal func on(event _: LiveObjectLifecycleEvent, callback _: @escaping LiveObjectLifecycleEventCallback) -> any OnLiveObjectLifecycleEventResponse {
         notYetImplemented()
     }
 

Sources/AblyLiveObjects/Internal/DefaultLiveMap.swift

@@ -183,15 +183,15 @@ internal final class InternalDefaultLiveMap: Sendable {
         notYetImplemented()
     }
 
-    internal func subscribe(listener _: LiveObjectUpdateCallback<LiveMapUpdate>) -> any SubscribeResponse {
+    internal func subscribe(listener _: @escaping LiveObjectUpdateCallback<LiveMapUpdate>) -> any SubscribeResponse {
         notYetImplemented()
     }
 
     internal func unsubscribeAll() {
         notYetImplemented()
     }
 
-    internal func on(event _: LiveObjectLifecycleEvent, callback _: LiveObjectLifecycleEventCallback) -> any OnLiveObjectLifecycleEventResponse {
+    internal func on(event _: LiveObjectLifecycleEvent, callback _: @escaping LiveObjectLifecycleEventCallback) -> any OnLiveObjectLifecycleEventResponse {
         notYetImplemented()
     }
 

Sources/AblyLiveObjects/Public/Public Proxy Objects/PublicDefaultLiveCounter.swift

@@ -34,15 +34,15 @@ internal final class PublicDefaultLiveCounter: LiveCounter {
         try await proxied.decrement(amount: amount)
     }
 
-    internal func subscribe(listener: sending LiveObjectUpdateCallback<LiveCounterUpdate>) -> any SubscribeResponse {
+    internal func subscribe(listener: sending @escaping LiveObjectUpdateCallback<LiveCounterUpdate>) -> any SubscribeResponse {
         proxied.subscribe(listener: listener)
     }
 
     internal func unsubscribeAll() {
         proxied.unsubscribeAll()
     }
 
-    internal func on(event: LiveObjectLifecycleEvent, callback: sending LiveObjectLifecycleEventCallback) -> any OnLiveObjectLifecycleEventResponse {
+    internal func on(event: LiveObjectLifecycleEvent, callback: sending @escaping LiveObjectLifecycleEventCallback) -> any OnLiveObjectLifecycleEventResponse {
         proxied.on(event: event, callback: callback)
     }
 

Sources/AblyLiveObjects/Public/Public Proxy Objects/PublicDefaultLiveMap.swift

@@ -80,15 +80,15 @@ internal final class PublicDefaultLiveMap: LiveMap {
         try await proxied.remove(key: key)
     }
 
-    internal func subscribe(listener: sending LiveObjectUpdateCallback<LiveMapUpdate>) -> any SubscribeResponse {
+    internal func subscribe(listener: sending @escaping LiveObjectUpdateCallback<LiveMapUpdate>) -> any SubscribeResponse {
         proxied.subscribe(listener: listener)
     }
 
     internal func unsubscribeAll() {
         proxied.unsubscribeAll()
     }
 
-    internal func on(event: LiveObjectLifecycleEvent, callback: sending LiveObjectLifecycleEventCallback) -> any OnLiveObjectLifecycleEventResponse {
+    internal func on(event: LiveObjectLifecycleEvent, callback: sending @escaping LiveObjectLifecycleEventCallback) -> any OnLiveObjectLifecycleEventResponse {
         proxied.on(event: event, callback: callback)
     }
 

Sources/AblyLiveObjects/Public/Public Proxy Objects/PublicDefaultRealtimeObjects.swift

@@ -51,7 +51,7 @@ internal final class PublicDefaultRealtimeObjects: RealtimeObjects {
         try await proxied.batch(callback: callback)
     }
 
-    internal func on(event: ObjectsEvent, callback: sending ObjectsEventCallback) -> any OnObjectsEventResponse {
+    internal func on(event: ObjectsEvent, callback: sending @escaping ObjectsEventCallback) -> any OnObjectsEventResponse {
         proxied.on(event: event, callback: callback)
     }
 

Sources/AblyLiveObjects/Public/PublicTypes.swift

@@ -70,7 +70,7 @@ public protocol RealtimeObjects: Sendable {
     ///   - callback: The event listener.
     /// - Returns: An ``OnObjectsEventResponse`` object that allows the provided listener to be deregistered from future updates.
     @discardableResult
-    func on(event: ObjectsEvent, callback: sending ObjectsEventCallback) -> OnObjectsEventResponse
+    func on(event: ObjectsEvent, callback: sending @escaping ObjectsEventCallback) -> OnObjectsEventResponse
 
     /// Deregisters all registrations, for all events and listeners.
     func offAll()
@@ -337,7 +337,7 @@ public protocol LiveObject: AnyObject, Sendable {
     /// - Parameter listener: An event listener function that is called with an update object whenever this LiveObject is updated.
     /// - Returns: A ``SubscribeResponse`` object that allows the provided listener to be deregistered from future updates.
     @discardableResult
-    func subscribe(listener: sending LiveObjectUpdateCallback<Update>) -> SubscribeResponse
+    func subscribe(listener: sending @escaping LiveObjectUpdateCallback<Update>) -> SubscribeResponse
 
     /// Deregisters all listeners from updates for this LiveObject.
     func unsubscribeAll()
@@ -349,7 +349,7 @@ public protocol LiveObject: AnyObject, Sendable {
     ///   - callback: The event listener.
     /// - Returns: A ``OnLiveObjectLifecycleEventResponse`` object that allows the provided listener to be deregistered from future updates.
     @discardableResult
-    func on(event: LiveObjectLifecycleEvent, callback: sending LiveObjectLifecycleEventCallback) -> OnLiveObjectLifecycleEventResponse
+    func on(event: LiveObjectLifecycleEvent, callback: sending @escaping LiveObjectLifecycleEventCallback) -> OnLiveObjectLifecycleEventResponse
 
     /// Deregisters all registrations, for all events and listeners.
     func offAll()