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

Function empty_buffer

clock-bound/src/daemon/async_ring_buffer.rs:347–353  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

345
346 #[tokio::test]
347 async fn empty_buffer() {
348 let (tx, _rx) = create::<i32>(2);
349 assert!(tx.is_empty());
350
351 tx.send(1).unwrap();
352 assert!(!tx.is_empty());
353 }
354
355 #[tokio::test]
356 async fn concurrent_send_receive() {

Callers

nothing calls this directly

Calls 1

sendMethod · 0.80

Tested by

no test coverage detected