Skip to content

Concurrency safe wrapper for (NS)Stream class cluster using Swift 5.5 Async/Await and Actors.

Notifications You must be signed in to change notification settings

AppAccount/AsyncStream

Repository files navigation

AsyncStream

Concurrency safe wrapper for (NS)Stream class cluster using Swift 5.5 Async/Await and Actors. InputStreamActor for reading from a stream oriented source and OutputStreamActor for writing to a stream oriented sink.

Use setWriteDataStream(_ writeDataStream: AsyncStream<Data>?) async to provide an AsyncStream of bytes to be delivered to the underlying OutputStream. Repeated calls to this method will block until the prior stream (if any) has finished.

Stream events are processed on RunLoop.current. As a client of this package, you are responsible for ensuring the RunLoop is actually running, whether using the main thread runloop or explicitly running a background thread runloop.

About

Concurrency safe wrapper for (NS)Stream class cluster using Swift 5.5 Async/Await and Actors.

Resources

Stars

Watchers

Forks

Packages

No packages published

Languages