[−][src]Function tari_test_utils::streams::assert_in_stream
pub async fn assert_in_stream<S, P, R>(
stream: &mut S,
predicate: P,
timeout: Duration
) -> R where
S: Stream + Unpin,
P: FnMut(S::Item) -> Option<R>,
pub async fn assert_in_stream<S, P, R>(
stream: &mut S,
predicate: P,
timeout: Duration
) -> R where
S: Stream + Unpin,
P: FnMut(S::Item) -> Option<R>,