Function ntex::util::stream_recv

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

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