MCPcopy Create free account
hub / github.com/aws/clock-bound / ClockStateHandle

Class ClockStateHandle

clock-bound/src/daemon.rs:295–300  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

293 match self.clock_state_handle.tx.send(source_params.clone()) {
294 Ok(()) => (),
295 Err(SendError::Disrupted(source_params)) => {
296 // don't handle_disruption. It will be handled on the next call of tokio::select
297 debug!(
298 ?source_params,
299 "Trying to send a value when there was a disruption event. Dropping."
300 );
301 }
302 Err(SendError::BufferClosed(e)) => {
303 error!(

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected