update async channels (#188)

Author: xlc

Networking/Package.swift

@@ -20,7 +20,7 @@ let package = Package(
         .package(url: "https://github.com/apple/swift-log.git", from: "1.6.0"),
         .package(url: "https://github.com/apple/swift-certificates.git", from: "1.5.0"),
         .package(url: "https://github.com/apple/swift-testing.git", branch: "0.10.0"),
-        .package(url: "https://github.com/gh123man/Async-Channels.git", from: "1.0.0"),
+        .package(url: "https://github.com/gh123man/Async-Channels.git", from: "1.0.2"),
     ],
     targets: [
         .target(

Networking/Sources/Networking/Stream.swift

@@ -71,17 +71,17 @@ final class Stream<Handler: StreamHandler>: Sendable, StreamProtocol {
         if data.isEmpty {
             return
         }
-        // TODO: backpressure handling
-        // https://github.com/gh123man/Async-Channels/issues/11
-        Task {
-            await channel.send(data)
+
+        if !channel.syncSend(data) {
+            logger.warning("stream \(id) is full")
+            // TODO: backpressure handling
         }
     }
 
     // initiate stream close
     public func close(abort: Bool = false) {
         if status != .open {
-            logger.warning("Trying to close stream \(stream.id) in status \(status)")
+            logger.warning("Trying to close stream \(id) in status \(status)")
             return
         }
         status = abort ? .aborted : .closed