search

wetware / pkg

Peer-to-peer cloud environment
https://wetware.run
Other
37 stars 7 forks source link

Add streaming send capability to csp.Chan #75

Closed lthibault closed 1 year ago

lthibault commented 1 year ago

This PR adds a NewStream method to csp.Chan and its derivatives. This adds support for flow-controlled streams to channels, which should greatly improve performance for large volumes of concurrent sends.

@mikelsr This is especially relevant to your work on processes, since iostream is implemented using csp.Chan under the hood. Use of csp.SendStream in iostream will be submitted in a separate PR.

(cc @aratz-lasa @evan-schott for general awareness. Code-review & feedback is most welcome.)

lthibault commented 1 year ago

(Fixes #74)

lthibault commented 1 year ago

Implements https://github.com/wetware/ww/issues/59