Function websocket_util::stream

pub async fn stream<S, I>(
    stream: S
) -> impl Stream<Item = Result<Result<I, JsonError>, WebSocketError>> where
    S: Sink<Message, Error = WebSocketError>,
    S: Stream<Item = Result<Message, WebSocketError>> + Unpin,
    I: DeserializeOwned, 

Create a stream of higher level primitives out of a client, honoring and filtering websocket control messages such as Ping and Close.