search

wetware / pkg

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

[ IGNORE ] Add streaming send capability to csp.Chan #74

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

Diff is all messed up. Closing and re-opening a under a new PR.