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)
| 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 | /// |