Add support for stream cloning#203
Conversation
| return | ||
|
|
||
| # close the local mem chan | ||
| rx_chan.close() |
There was a problem hiding this comment.
This likely needs to be put above.
Thanks to @richardsheridan for catching 🏄🏼
|
Heh, so this doesn't even work remotely as planned 😂 Turns out receive mem chans do not support broadcasting in
This actually ended up being a source of major confusion in pikers/piker#158 where this PR's change to So basically I think we need to drop this idea wholesale (at least if we're sticking with clone as it has meaning in |
|
See also #53 for further discussion on how we don't want |
Leverage
trio's built-in rx channel cloning with ourReceiveStreamto enable multi-consumer usage.