Results for stream_throttle

Provides a Stream combinator, to limit the rate at which items are produced.

throttle stream

Time-based operators extending fluxion-stream with monotonic timestamps

Flush-on-newline buffer for streaming LLM output. Holds bytes until a newline or N millis pass, then yields a complete chunk. Zero deps.

Rx implementations for the futures crate

tokio-netem — pragmatic AsyncRead, AsyncWrite I/O adapters for chaos & network emulation

AWS Rekognition Face Liveness for Tauri 2 — native Android/iOS UI bindings.

A high-performance, production-ready async streaming library for Rust.

TimeoutIterator is a wrapper over any iterator that adds peek_timeout and next_timeout functions. The canonical use-case is parsing multi-line free-form records (such as tailing a log fime) where it is desirable to consume the very last line, and peek whether the record continues on the next time, but not block indefinitely on the peek.

a collection of selected rxjs operators for rust standard Stream

HTTP body streaming support for Axum: json/csv/protobuf/arrow/txt

PostgreSQL logical replication protocol library - parse and handle PostgreSQL WAL streaming messages