Function futures_lite::stream::race
source · pub fn race<T, S1, S2>(stream1: S1, stream2: S2) -> Race<S1, S2>
Expand description
Merges two streams, with no preference for either stream when both are ready.
§Examples
use futures_lite::stream::{self, once, pending, StreamExt};
assert_eq!(stream::race(once(1), pending()).next().await, Some(1));
assert_eq!(stream::race(pending(), once(2)).next().await, Some(2));
// One of the two stream is randomly chosen as the winner.
let res = stream::race(once(1), once(2)).next().await;