(
req: Result<SqlRequest, Error>,
client: &mut AuthedClient,
ws: &mut WebSocket,
)
| 471 | } |
| 472 | |
| 473 | async fn run_ws_request( |
| 474 | req: Result<SqlRequest, Error>, |
| 475 | client: &mut AuthedClient, |
| 476 | ws: &mut WebSocket, |
| 477 | ) -> Result<(), Error> { |
| 478 | let req = req?; |
| 479 | execute_request(client, req, ws).await |
| 480 | } |
| 481 | |
| 482 | /// Sends a single [`WebSocketResponse`] over the provided [`WebSocket`]. |
| 483 | async fn send_ws_response(ws: &mut WebSocket, resp: WebSocketResponse) -> Result<(), Error> { |
no test coverage detected