I have one
impl Stream<Item=Cloneable> and would like to have two independent
impl Stream<Item=Cloneable>s with this content.
How can I do that using std futures?
The tricky problems:
- I'd like backpressure/finite amount of buffering. The source should be polled only as fast as both destinations can manage to read.
- If one of the streams is dropped, it should not harm the other one.
- If both streams are dropped, the source should be dropped as well.
I have a hunch that it will require one or more async
mpsc and sinks, but I'm not sure exactly how to put these together.