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

Method take_internal_response

src/controller/src/lib.rs:323–326  ·  view source on GitHub ↗

Returns `Some` if there is an immediately available internally-generated response that we need to return to the client (as opposed to waiting for a response from compute or storage).

(&mut self)

Source from the content-addressed store, hash-verified

321 /// internally-generated response that we need to return to the
322 /// client (as opposed to waiting for a response from compute or storage).
323 fn take_internal_response(&mut self) -> Option<ControllerResponse> {
324 let ws = std::mem::take(&mut self.immediate_watch_sets);
325 (!ws.is_empty()).then_some(ControllerResponse::WatchSetFinished(ws))
326 }
327
328 /// Waits until the controller is ready to process a response.
329 ///

Callers 1

readyMethod · 0.80

Calls 2

takeFunction · 0.85
is_emptyMethod · 0.45

Tested by

no test coverage detected