merge: optimize task creation and remove sendable constraint

Author: twittemb

Sources/AsyncAlgorithms/AsyncChannel.swift

@@ -28,7 +28,9 @@ public final class AsyncChannel<Element: Sendable>: AsyncSequence, Sendable {
     init(_ channel: AsyncChannel<Element>) {
       self.channel = channel
     }
-    
+
+
+
     /// Await the next sent element or finish.
     public mutating func next() async -> Element? {
       guard active else {
@@ -116,7 +118,7 @@ public final class AsyncChannel<Element: Sendable>: AsyncSequence, Sendable {
 
   /// Create a new `AsyncChannel` given an element type.
   public init(element elementType: Element.Type = Element.self) { }
-  
+
   func establish() -> Int {
     state.withCriticalRegion { state in
       defer { state.generation &+= 1 }

Sources/AsyncAlgorithms/AsyncChunksOfCountOrSignalSequence.swift

@@ -68,7 +68,7 @@ public struct AsyncChunksOfCountOrSignalSequence<Base: AsyncSequence, Collected:
       self.count = count
       self.state = Merge2StateMachine(base, terminatesOnNil: true, signal)
     }
-    
+
     public mutating func next() async rethrows -> Collected? {
       var result : Collected?
       while let next = try await state.next() {