The Code AsyncWebsocketClient I’m currently working on an AsyncWebsocketClient which is using tokio_tungstenite internally, respectively futures::Sink<tokio_tungstenite::Message, Error = tokio_tungstenite::tungstenite::Error> and futures::Stream<Item = Result<tokio_tungstenite::Message, tokio_tungstenite::tungstenite::Error>>. AsyncWebsocketClient also implements futures::Sink and futures::Stream but uses String as Item. So the AsyncWebsocketClient looks like this: pub struct AsyncWebsocketClient<T, M = SingleExecutorMutex, Status = WebsocketClosed> where M: RawMutex, { websocket: […]