Function changes

pub fn changes(
    stream: WebSocketStream<MaybeTlsStream<TcpStream>>,
) -> Map<SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, impl FnMut(Result<Message, Error>) -> Result<Pin<Box<dyn Future<Output = Result<ChangeNotification, Error>> + Send>>, Error>>

Available on crate features listen and network-client only.

Read change messages from a websocket stream, and decode to change notifications that can be processed.