Function ntex_util::future::stream_recv

pub async fn stream_recv<S>(stream: &mut S) -> Option<S::Item>
where
    S: Stream + Unpin,

Creates a future that resolves to the next item in the stream.