(&mut self, msg: Message)
| 302 | } |
| 303 | |
| 304 | async fn send(&mut self, msg: Message) -> WsResult { |
| 305 | if self.socket.send(msg).await.is_err() { |
| 306 | // client disconnected |
| 307 | Err(WsCloseReason::ClientDisconnected) |
| 308 | } else { |
| 309 | Ok(()) |
| 310 | } |
| 311 | } |
| 312 | |
| 313 | async fn send_event(&mut self, evt: WsEvent) -> WsResult { |
| 314 | let encoded = serde_json::to_string(&evt).map_err(|_| WsCloseReason::JsonEncodeError)?; |
no outgoing calls
no test coverage detected