Mock Type implementing AsyncRead/AsyncWrite for testing and examples.
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
Async SPSC FIFO ring buffer
I'm at the buffer pool. I'm at the MPSC channel. I'm at the combination MPSC channel and buffer pool.
A simple, educational implementation of channels in Rust.
Maintenance fork of the unmaintained `buf_redux` 0.8.4 with the `trailing_semicolon_in_macro` future-incompatibility warnings fixed. Drop-in replacement; otherwise identical to the original.
A Tokio async, sharded SPSC/MPSC/MPMC ring buffer in Rust.
An async, lock-free, sharded, cache-aware SPSC/MPSC/MPMC ring buffer in Rust.