[Enhancement]Improve swift concurrency task lifecycle by ipavlidakis · Pull Request #861 · GetStream/stream-video-swift

ipavlidakis · 2025-06-20T15:51:03Z

🎯 Goal

Improve Swift Concurrency Task lifecycle by 1. providing a simple way to manage a Task's lifecycle, 2. avoid keeping Tasks in memory to reduce memory usage.

☑️ Contributor Checklist

I have signed the Stream CLA (required)
This change follows zero ⚠️ policy (required)
This change should receive manual QA
Changelog is updated with client-facing changes
New code is covered by unit tests
Comparison screenshots added for visual changes
Affected documentation updated (tutorial, CMS)

Stream-SDK-Bot · 2025-06-20T16:02:22Z

SDK Size

`title`	`develop`	`branch`	`diff`	`status`
StreamVideo	7.93 MB	8.06 MB	+137 KB	🟢
StreamVideoSwiftUI	2.25 MB	2.27 MB	+18 KB	🟢
StreamVideoUIKit	2.38 MB	2.39 MB	+17 KB	🟢
StreamWebRTC	9.85 MB	9.85 MB	0 KB	🟢

github-actions · 2025-06-20T16:07:35Z

Public Interface

+ public protocol Signposting

+ public actor SerialActorQueue  
+ 
+   nonisolated public var unownedExecutor: UnownedSerialExecutor
+   
+ 
+   public init(file: StaticString = #file)
+   
+ 
+   @discardableResult public nonisolated func async(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext operation: @escaping Operation)-> QueueTask
+   @discardableResult public nonisolated func async(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext operation: @escaping @Sendable() async -> Void)-> QueueTask
+   @discardableResult public nonisolated func sync(@_inheritActorContext operation: @escaping @Sendable() async throws -> Output)async throws -> Output
+   @discardableResult public nonisolated func async(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Void)-> QueueTask
+   @discardableResult public nonisolated func sync(@_inheritActorContext operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Output)async throws -> Output
+   public nonisolated func cancelAll()
+   
+ 
+   public final class QueueTask: @unchecked Sendable

- public final class SerialActorQueue: Sendable  
- 
-   public init()
-   
- 
-   public func cancelAll()
-   public func async(file: StaticString = #file,functionName: StaticString = #function,line: UInt = #line,_ block: @Sendable @escaping () async throws -> Void)
-   public func sync(_ block: @Sendable @escaping () async throws -> T)async throws -> T

 public final class CurrentDevice: @unchecked Sendable  
+     case simulator

 extension Task  
-   public func store(in disposableBag: DisposableBag,key: String = UUID().uuidString)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async -> Success)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async throws -> Success)
+   
+ 
+   public func store(in disposableBag: DisposableBag,identifier: String = UUID().uuidString)

- public enum CallingState: Equatable, CustomStringConvertible  
+ public enum CallingState: Equatable, CustomStringConvertible, Sendable  

 public final class DisposableBag: @unchecked Sendable  
+   public func completed(_ key: String)

 extension Publisher  
-   public func sinkTask(storeIn disposableBag: DisposableBag? = nil,identifier: String? = nil,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
+   public func sinkTask(storeIn disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
-   public func sinkTask(queue: SerialActorQueue,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
+   public func sinkTask(queue: SerialActorQueue,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable

github-actions · 2025-06-20T16:07:39Z

	1 Error
🚫	Please use more than one word. `0b7da11`

	1 Warning
⚠️	Big PR

Generated by 🚫 Danger

github-actions · 2025-06-23T08:25:28Z

Public Interface

+ extension OperationQueue  
+ 
+   public func addTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Void)
+   public func addSynchronousTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,timeout: TimeInterval = 10,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Output)async throws -> Output

+ public protocol Signposting

- public final class SerialActorQueue: Sendable  
- 
-   public init()
-   
- 
-   public func cancelAll()
-   public func async(file: StaticString = #file,functionName: StaticString = #function,line: UInt = #line,_ block: @Sendable @escaping () async throws -> Void)
-   public func sync(_ block: @Sendable @escaping () async throws -> T)async throws -> T

- public enum CallingState: Equatable, CustomStringConvertible  
+ public enum CallingState: Equatable, CustomStringConvertible, Sendable  

 extension Publisher  
-   public func sinkTask(storeIn disposableBag: DisposableBag? = nil,identifier: String? = nil,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
+   public func sinkTask(storeIn disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
-   public func sinkTask(queue: SerialActorQueue,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable

 public final class CurrentDevice: @unchecked Sendable  
+     case simulator

 public final class DisposableBag: @unchecked Sendable  
+   public func completed(_ key: String)

 extension Task  
-   public func store(in disposableBag: DisposableBag,key: String = UUID().uuidString)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async -> Success)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async throws -> Success)
+   
+ 
+   public func store(in disposableBag: DisposableBag,identifier: String = UUID().uuidString)

github-actions · 2025-06-23T09:03:34Z

Public Interface

+ extension OperationQueue  
+ 
+   public func addTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Void)
+   public func addSynchronousTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,timeout: TimeInterval = 10,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Output)async throws -> Output

+ public protocol Signposting

- public final class SerialActorQueue: Sendable  
- 
-   public init()
-   
- 
-   public func cancelAll()
-   public func async(file: StaticString = #file,functionName: StaticString = #function,line: UInt = #line,_ block: @Sendable @escaping () async throws -> Void)
-   public func sync(_ block: @Sendable @escaping () async throws -> T)async throws -> T

- public enum CallingState: Equatable, CustomStringConvertible  
+ public enum CallingState: Equatable, CustomStringConvertible, Sendable  

 public final class DisposableBag: @unchecked Sendable  
+   public func completed(_ key: String)

 public final class CurrentDevice: @unchecked Sendable  
+     case simulator

 extension Publisher  
-   public func sinkTask(storeIn disposableBag: DisposableBag? = nil,identifier: String? = nil,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
+   public func sinkTask(storeIn disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
-   public func sinkTask(queue: SerialActorQueue,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable

 extension Task  
-   public func store(in disposableBag: DisposableBag,key: String = UUID().uuidString)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async -> Success)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async throws -> Success)
+   
+ 
+   public func store(in disposableBag: DisposableBag,identifier: String = UUID().uuidString)

github-actions · 2025-06-23T11:15:33Z

Public Interface

+ public protocol Signposting

+ extension OperationQueue  
+ 
+   public func addTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Void)
+   public func addSynchronousTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,timeout: TimeInterval = 10,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Output)async throws -> Output

- public final class SerialActorQueue: Sendable  
- 
-   public init()
-   
- 
-   public func cancelAll()
-   public func async(file: StaticString = #file,functionName: StaticString = #function,line: UInt = #line,_ block: @Sendable @escaping () async throws -> Void)
-   public func sync(_ block: @Sendable @escaping () async throws -> T)async throws -> T

- public enum CallingState: Equatable, CustomStringConvertible  
+ public enum CallingState: Equatable, CustomStringConvertible, Sendable  

 public final class DisposableBag: @unchecked Sendable  
+   public func completed(_ key: String)

 extension Task  
-   public func store(in disposableBag: DisposableBag,key: String = UUID().uuidString)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async -> Success)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async throws -> Success)
+   
+ 
+   public func store(in disposableBag: DisposableBag,identifier: String = UUID().uuidString)

 public final class CurrentDevice: @unchecked Sendable  
+     case simulator

 extension Publisher  
-   public func sinkTask(storeIn disposableBag: DisposableBag? = nil,identifier: String? = nil,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
+   public func sinkTask(storeIn disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
-   public func sinkTask(queue: SerialActorQueue,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable

martinmitrevski

Impressive work 👏 Added a few small comments and we should check the failed checks before merging.

martinmitrevski · 2025-06-23T11:25:56Z


    /// Deinitializes the instance, deallocating the unfair lock.
    deinit {
+        lock.deinitialize(count: 1)


Because the allocated capacity was 1, so we are only deinitializing what we allocated intially.

Yes, but the problem is what if we change something in the future - we always have to remember to update this as well?

martinmitrevski · 2025-06-23T11:59:01Z

    /// Cleans up resources when the instance is being deallocated.
    deinit {
        peerConnection.transceivers.forEach { $0.stopInternal() }
+        // swiftlint:disable discourage_task_init


maybe we're too strict with this rule?

That's actually intended. The plan is to avoid having Tasks that there is no way to control their lifecycle (e.g. cancel them). Do you think we should relax it?

I think so - we should have this only in the core parts. What do you think?

github-actions · 2025-06-23T13:58:52Z

Public Interface

+ extension OperationQueue  
+ 
+   public func addTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Void)
+   public func addSynchronousTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,timeout: TimeInterval = 5,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Output)async throws -> Output

+ public protocol Signposting

- public final class SerialActorQueue: Sendable  
- 
-   public init()
-   
- 
-   public func cancelAll()
-   public func async(file: StaticString = #file,functionName: StaticString = #function,line: UInt = #line,_ block: @Sendable @escaping () async throws -> Void)
-   public func sync(_ block: @Sendable @escaping () async throws -> T)async throws -> T

- public enum CallingState: Equatable, CustomStringConvertible  
+ public enum CallingState: Equatable, CustomStringConvertible, Sendable  

 public final class CurrentDevice: @unchecked Sendable  
+     case simulator

 public final class DisposableBag: @unchecked Sendable  
+   public func completed(_ key: String)

 extension Publisher  
-   public func sinkTask(storeIn disposableBag: DisposableBag? = nil,identifier: String? = nil,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
+   public func sinkTask(storeIn disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
-   public func sinkTask(queue: SerialActorQueue,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable

 extension Task  
-   public func store(in disposableBag: DisposableBag,key: String = UUID().uuidString)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async -> Success)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async throws -> Success)
+   
+ 
+   public func store(in disposableBag: DisposableBag,identifier: String = UUID().uuidString)

github-actions · 2025-06-23T14:47:02Z

Public Interface

+ public protocol Signposting

+ extension OperationQueue  
+ 
+   public func addTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Void)
+   public func addSynchronousTaskOperation(file: StaticString = #file,function: StaticString = #function,line: UInt = #line,timeout: TimeInterval = 5,operation: sending @escaping @Sendable @isolated(any) () async throws (Failure) -> Output)async throws -> Output

- public final class SerialActorQueue: Sendable  
- 
-   public init()
-   
- 
-   public func cancelAll()
-   public func async(file: StaticString = #file,functionName: StaticString = #function,line: UInt = #line,_ block: @Sendable @escaping () async throws -> Void)
-   public func sync(_ block: @Sendable @escaping () async throws -> T)async throws -> T

- public enum CallingState: Equatable, CustomStringConvertible  
+ public enum CallingState: Equatable, CustomStringConvertible, Sendable  

 extension Publisher  
-   public func sinkTask(storeIn disposableBag: DisposableBag? = nil,identifier: String? = nil,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
+   public func sinkTask(storeIn disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
-   public func sinkTask(queue: SerialActorQueue,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable

 public final class CurrentDevice: @unchecked Sendable  
+     case simulator

 extension Task  
-   public func store(in disposableBag: DisposableBag,key: String = UUID().uuidString)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async -> Success)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async throws -> Success)
+   
+ 
+   public func store(in disposableBag: DisposableBag,identifier: String = UUID().uuidString)

 public final class DisposableBag: @unchecked Sendable  
+   public func completed(_ key: String)

github-actions · 2025-06-23T16:27:12Z

Public Interface

+ public protocol Signposting

- public final class SerialActorQueue: Sendable  
- 
-   public init()
-   
- 
-   public func cancelAll()
-   public func async(file: StaticString = #file,functionName: StaticString = #function,line: UInt = #line,_ block: @Sendable @escaping () async throws -> Void)
-   public func sync(_ block: @Sendable @escaping () async throws -> T)async throws -> T

 public final class CurrentDevice: @unchecked Sendable  
+     case simulator

 public final class DisposableBag: @unchecked Sendable  
+   public func completed(_ key: String)

 extension Publisher  
-   public func sinkTask(storeIn disposableBag: DisposableBag? = nil,identifier: String? = nil,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
+   public func sinkTask(storeIn disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable
-   public func sinkTask(queue: SerialActorQueue,receiveCompletion: @escaping (@Sendable(Subscribers.Completion<Failure>) -> Void) = { _ in },receiveValue: @escaping (@Sendable(Output) async throws -> Void))-> AnyCancellable

- public enum CallingState: Equatable, CustomStringConvertible  
+ public enum CallingState: Equatable, CustomStringConvertible, Sendable  

 extension Task  
-   public func store(in disposableBag: DisposableBag,key: String = UUID().uuidString)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async -> Success)
+   @discardableResult public init(disposableBag: DisposableBag,identifier: String = UUIDProviderKey.currentValue.get().uuidString,priority: TaskPriority? = nil,subsystem: LogSubsystem = .other,file: StaticString = #file,function: StaticString = #function,line: UInt = #line,@_inheritActorContext block: @Sendable @escaping () async throws -> Success)
+   
+ 
+   public func store(in disposableBag: DisposableBag,identifier: String = UUID().uuidString)

sonarqubecloud · 2025-06-23T16:45:53Z

Quality Gate passed

Issues
8 New issues
0 Accepted issues

Measures
0 Security Hotspots
80.5% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud

ipavlidakis self-assigned this Jun 20, 2025

ipavlidakis requested a review from a team as a code owner June 20, 2025 15:51

ipavlidakis added the bug Something isn't working label Jun 20, 2025

ipavlidakis added 12 commits June 23, 2025 15:00

[Performance]Break async stream memory leaks

ad47046

Remove unnecessary MainActor modifiers

e7f0119

[Performance]Dispose completed tasks and improve serial execution

209ee07

Assign all tasks to disposable bags

9fcb34a

Add executor to every actor

77e1b09

Disable callkitService on simulators

9bc0b11

Signpost

0b7da11

Remove Task priority default setting to .background

4bf3b67

Improve timings

3215336

Replace SerialActorQueue with OperationQueue

0bcd166

Fix tests

0ac14f5

Fix tests

c821d5e

martinmitrevski reviewed Jun 23, 2025

View reviewed changes

ipavlidakis added 2 commits June 23, 2025 16:36

Fix tests

470b2b7

Update nextValue to make it more stable

6a6c124

ipavlidakis force-pushed the enhancement/improve-swift-concurrency-task-lifecycle branch from 2cd6cc1 to 6a6c124 Compare June 23, 2025 13:56

Address feedback and fix tests

68608d9

martinmitrevski approved these changes Jun 23, 2025

View reviewed changes

Fix xcode 15 build

97f9ee3

ipavlidakis merged commit c9b6db3 into develop Jun 23, 2025

ipavlidakis deleted the enhancement/improve-swift-concurrency-task-lifecycle branch June 23, 2025 17:34

ipavlidakis mentioned this pull request Jun 24, 2025

1.27.0 Release #862

Merged

Uh oh!

Conversation

ipavlidakis commented Jun 20, 2025

🎯 Goal

☑️ Contributor Checklist

Uh oh!

Stream-SDK-Bot commented Jun 20, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

SDK Size

Uh oh!

github-actions Bot commented Jun 20, 2025

Public Interface

Uh oh!

github-actions Bot commented Jun 20, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

github-actions Bot commented Jun 23, 2025

Public Interface

Uh oh!

github-actions Bot commented Jun 23, 2025

Public Interface

Uh oh!

github-actions Bot commented Jun 23, 2025

Public Interface

Uh oh!

martinmitrevski left a comment

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

martinmitrevski Jun 23, 2025

Choose a reason for hiding this comment

Uh oh!

ipavlidakis Jun 23, 2025

Choose a reason for hiding this comment

Uh oh!

martinmitrevski Jun 23, 2025

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

martinmitrevski Jun 23, 2025

Choose a reason for hiding this comment

Uh oh!

ipavlidakis Jun 23, 2025

Choose a reason for hiding this comment

Uh oh!

martinmitrevski Jun 23, 2025

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

github-actions Bot commented Jun 23, 2025

Public Interface

Uh oh!

github-actions Bot commented Jun 23, 2025

Public Interface

Uh oh!

github-actions Bot commented Jun 23, 2025

Public Interface

Uh oh!

sonarqubecloud Bot commented Jun 23, 2025

Quality Gate passed

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Stream-SDK-Bot commented Jun 20, 2025 •

edited

Loading

github-actions Bot commented Jun 20, 2025 •

edited

Loading