dtact-util 0.2.0

Async utilities for Dtact: I/O, filesystem, process, signal, stream and timer primitives with lock-free native (io_uring/IOCP/kqueue) and tokio backends. Designed for hardware-level control and non-blocking heterogeneous orchestration.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! In-process duplex byte-stream pipes.
//!
//! Two backends, selected the same way as [`crate::io`] and [`crate::fs`]:
//! - `native` (default): a lock-free duplex pipe built directly on
//!   [`crate::lockfree::SpscQueue`] (one ring buffer per direction, single
//!   producer/single consumer per ring — exactly what a two-endpoint pipe
//!   needs) plus [`crate::lockfree::AtomicWakerSlot`] for backpressure/data-
//!   availability notification. No `Mutex`, no per-call heap allocation.
//! - `tokio` (when `native` is off): a thin wrapper over
//!   `tokio::io::duplex`.

#[cfg(feature = "native")]
mod native;
#[cfg(feature = "native")]
pub use native::*;

// NOTE: named `tokio_backend`, not `tokio` — see `io::mod`/`fs::mod` for
// why a local module literally named `tokio` shadows the extern crate.
#[cfg(all(feature = "tokio", not(feature = "native")))]
mod tokio_backend;
#[cfg(all(feature = "tokio", not(feature = "native")))]
pub use tokio_backend::*;