Merge branch 'improve/sync-send'

Author: Thibault Wittemberg

CHANGELOG.md

@@ -1,7 +1,8 @@
 **v0.3.0 - Beryllium:**
 
-- new Share operator
-- new Timer AsyncSequence
+- Operators: new Share operator
+- AsyncSequences: new Timer AsyncSequence
+- AsyncStreams: `send()` functions are now synchronous
 
 **v0.2.1 - Lithium:**
 

Sources/AsyncStreams/AsyncStreams+CurrentValue.swift

@@ -85,7 +85,7 @@ public final class AsyncCurrentValueStream<Element>: Stream, @unchecked Sendable
     /// Sends a value to all underlying async sequences
     /// - Parameter element: the value to send
     public func send(_ element: Element) {
-        self.serialQueue.async { [weak self] in
+        self.serialQueue.sync { [weak self] in
             self?.storage.update(element)
             self?.continuations.send(element)
         }
@@ -94,7 +94,7 @@ public final class AsyncCurrentValueStream<Element>: Stream, @unchecked Sendable
     /// Finishes the async sequences with either a normal ending or an error.
     /// - Parameter termination: The termination to finish the async sequence.
     public func send(termination: Termination) {
-        self.serialQueue.async { [weak self] in
+        self.serialQueue.sync { [weak self] in
             self?.continuations.send(termination)
         }
     }

Sources/AsyncStreams/AsyncStreams+Passthrough.swift

@@ -51,15 +51,15 @@ public final class AsyncPassthroughStream<Element>: Stream, @unchecked Sendable
     /// Sends a value to all underlying async sequences
     /// - Parameter element: the value to send
     public func send(_ element: Element) {
-        self.serialQueue.async { [weak self] in
+        self.serialQueue.sync { [weak self] in
             self?.continuations.send(element)
         }
     }
 
     /// Finishes the async sequences with either a normal ending or an error.
     /// - Parameter termination: The termination to finish the async sequence.
     public func send(termination: Termination) {
-        self.serialQueue.async { [weak self] in
+        self.serialQueue.sync { [weak self] in
             self?.continuations.send(termination)
         }
     }

Sources/AsyncStreams/AsyncStreams+Replay.swift

@@ -76,7 +76,7 @@ public final class AsyncReplayStream<Element>: Stream, @unchecked Sendable {
     /// Sends a value to all underlying async sequences
     /// - Parameter element: the value to send
     public func send(_ element: Element) {
-        self.serialQueue.async { [weak self] in
+        self.serialQueue.sync { [weak self] in
             self?.storage.push(element)
             self?.continuations.send(element)
         }
@@ -85,7 +85,7 @@ public final class AsyncReplayStream<Element>: Stream, @unchecked Sendable {
     /// Finishes the async sequences with either a normal ending or an error.
     /// - Parameter completion: The termination to finish the async sequence.
     public func send(termination: Termination) {
-        self.serialQueue.async { [weak self] in
+        self.serialQueue.sync { [weak self] in
             self?.continuations.send(termination)
             self?.storage.clear()
         }