Skip to main content

until_stream

agent_rex

Function until_stream 

Source 
pub fn until_stream<T, U, S: Stream<Item = T> + Unpin, Stop: Stream<Item = U> + Unpin>(
    stop: Stop,
    source: S,
) -> impl Stream<Item = T>
Expand description

Emit from source until stop stream emits. Runtime-agnostic using futures::select!