[−][src]Function websocket_util::stream
pub async fn stream<S>(
stream: S
) -> impl Stream<Item = Result<Vec<u8>, WebSocketError>> where
S: Sink<Message, Error = WebSocketError>,
S: Stream<Item = Result<Message, WebSocketError>> + Unpin,
Create a stream of higher level primitives out of a client, honoring
and filtering websocket control messages such as Ping
and Close
.