ntex_util::future

Function stream_recv

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

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