Function drive_ws_stream 

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