pub async fn stream_recv<S>(stream: &mut S) -> Option<S::Item>where S: Stream + Unpin,
Waits for and returns the next item from a stream.