[Fix]Flakey tests (#440)

GetStream · Jun 18, 2024 · 6ca703f · 6ca703f
1 parent 77b0a4d
commit 6ca703f
Show file tree

Hide file tree

Showing 6 changed files with 154 additions and 80 deletions.
diff --git a/Sources/StreamVideo/StreamVideo.swift b/Sources/StreamVideo/StreamVideo.swift
@@ -170,20 +170,30 @@ public class StreamVideo: ObservableObject, @unchecked Sendable {
         connectTask = Task {
             if user.type == .guest {
                 do {
+                    try Task.checkCancellation()
                     let guestInfo = try await loadGuestUserInfo(for: user, apiKey: apiKey)
+
                     self.state.user = guestInfo.user
                     self.token = guestInfo.token
                     self.tokenProvider = guestInfo.tokenProvider
+
+                    try Task.checkCancellation()
                     try await self.connectUser(isInitial: true)
                 } catch {
                     log.error("Error connecting as guest", error: error)
                 }
             } else {
+                try Task.checkCancellation()
                 try await self.connectUser(isInitial: true)
             }
         }
     }
 
+    deinit {
+        connectTask?.cancel()
+        connectTask = nil
+    }
+
     /// Connects the current user.
     public func connect() async throws {
         try await connectUser()

diff --git a/...s/StreamVideoSwiftUI/Utils/PictureInPicture/StreamPictureInPictureTrackStateAdapter.swift b/...s/StreamVideoSwiftUI/Utils/PictureInPicture/StreamPictureInPictureTrackStateAdapter.swift
@@ -35,6 +35,12 @@ final class StreamPictureInPictureTrackStateAdapter {
         }
     }
 
+    deinit {
+        observerCancellable?.cancel()
+        isEnabled = false
+        activeTrack = nil
+    }
+
     // MARK: - Private helpers
 
     /// This property holds a reference to the observer cancellable.