async fn socket_read_fut<T: ThreadableSocket<S, R>, S, R>( socket: &mut Option<T>, ) -> Result<TextOrT<Vec<u8>>, ()>
A future that yields the next message from the socket, or never if the socket is None