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