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.