MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / run_ws_request

Function run_ws_request

src/environmentd/src/http/sql.rs:473–480  ·  view source on GitHub ↗
(
    req: Result<SqlRequest, Error>,
    client: &mut AuthedClient,
    ws: &mut WebSocket,
)

Source from the content-addressed store, hash-verified

471}
472
473async 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`].
483async fn send_ws_response(ws: &mut WebSocket, resp: WebSocketResponse) -> Result<(), Error> {

Callers 1

run_wsFunction · 0.85

Calls 1

execute_requestFunction · 0.85

Tested by

no test coverage detected