Changes from feat/listeners

pubnub · Aug 20, 2024 · 19b7e20 · 19b7e20
1 parent 7403207
commit 19b7e20
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/Sources/PubNub/EventEngine/Subscribe/SubscribeTransition.swift b/Sources/PubNub/EventEngine/Subscribe/SubscribeTransition.swift
@@ -30,7 +30,7 @@ class SubscribeTransition: TransitionProtocol {
     case .subscriptionRestored:
       return true
     case .unsubscribeAll:
-      return true
+      return !(state is Subscribe.UnsubscribedState)
     case .disconnect:
       return !(
         state is Subscribe.HandshakeStoppedState || state is Subscribe.ReceiveStoppedState ||

diff --git a/Sources/PubNub/Events/New/EventListenerInterface.swift b/Sources/PubNub/Events/New/EventListenerInterface.swift
@@ -28,7 +28,7 @@ public class StatusListener: StatusListenerInterface {
   public let queue: DispatchQueue
   public var onConnectionStateChange: ((ConnectionStatus) -> Void)?
 
-  init(
+  public init(
     uuid: UUID = UUID(),
     queue: DispatchQueue = .main,
     onConnectionStateChange: @escaping ((ConnectionStatus) -> Void)
@@ -80,7 +80,7 @@ public class EventListener: EventListenerInterface {
   public var onFileEvent: ((PubNubFileChangeEvent) -> Void)?
   public var onAppContext: ((PubNubAppContextEvent) -> Void)?
 
-  init(
+  public init(
     queue: DispatchQueue = .main,
     uuid: UUID = UUID(),
     onEvent: ((PubNubEvent) -> Void)? = nil,

diff --git a/Sources/PubNub/Subscription/SubscriptionSession.swift b/Sources/PubNub/Subscription/SubscriptionSession.swift
@@ -315,7 +315,7 @@ extension SubscriptionSession {
         return nil
       }
     }.filter {
-      !(Set($0.subscriptionTopology[subscription.subscriptionType] ?? []).intersection(namesToFind).isEmpty)
+      !(Set($0.subscriptionTopology[subscription.subscriptionType] ?? []).isDisjoint(with: namesToFind))
     }
   }