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>,