streamweave_stdio/
lib.rs

1//! Standard I/O (stdio) integration for StreamWeave
2//!
3//! This package provides producers and consumers for integrating StreamWeave
4//! with POSIX standard streams (stdin, stdout, stderr).
5//!
6//! ## Producer
7//!
8//! The `StdinProducer` reads lines from standard input (stdin) and produces
9//! them into a StreamWeave stream.
10//!
11//! ## Consumers
12//!
13//! - **`StdoutConsumer`**: Writes items from a StreamWeave stream to standard output (stdout)
14//! - **`StderrConsumer`**: Writes items from a StreamWeave stream to standard error (stderr)
15//!
16//! ## Example
17//!
18//! ```rust,no_run
19//! use streamweave_stdio::{StdinProducer, StdoutConsumer};
20//! use streamweave::Pipeline;
21//!
22//! let pipeline = Pipeline::new()
23//!     .producer(StdinProducer::new())
24//!     .transformer(/* ... */)
25//!     .consumer(StdoutConsumer::new());
26//! ```
27
28pub mod consumers;
29pub mod producers;
30
31pub use consumers::*;
32pub use producers::*;