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

Method handle_disruption

clock-bound/src/daemon/async_ring_buffer.rs:100–103  ·  view source on GitHub ↗

Handle a clock disruption event This clears the internal buffer and leaves a marker that sender has handled it.

(&self)

Source from the content-addressed store, hash-verified

98 ///
99 /// This clears the internal buffer and leaves a marker that sender has handled it.
100 pub fn handle_disruption(&self) {
101 #[expect(clippy::missing_panics_doc, reason = "not handling poisoned mutex")]
102 self.inner.lock().unwrap().handle_disruption_sender();
103 }
104
105 /// Return true if the buffer is empty
106 #[expect(clippy::missing_panics_doc, reason = "not handling poisoned mutex")]

Calls 2

Tested by

no test coverage detected