async fn drive_ws_stream<T: Serialize>( socket: WebSocket, stream: BoxStream<'static, T>, format: WsFormat, )