Function bicoro::broadcast_until_finished
source · pub fn broadcast_until_finished<'a, I, O, A, B>(
first: Coroutine<'a, I, O, A>,
second: Coroutine<'a, I, O, B>
) -> Coroutine<'a, I, O, (A, B)>where
I: Clone,
A: Send,
B: Send,
O: Send,
Expand description
Sends inputs to both coroutines, and will emit outputs together
If one finishes first, the other will consume the inputs until it is finished. Both routines must finish to return Input must be cloneable as it will need to feed both This is similar to broadcast, but continues running the ‘last’ routine