Crate streamweave_stdio 

Standard I/O (stdio) integration for StreamWeave

This package provides producers and consumers for integrating StreamWeave with POSIX standard streams (stdin, stdout, stderr).

Producer

The StdinProducer reads lines from standard input (stdin) and produces them into a StreamWeave stream.

Consumers

• StdoutConsumer: Writes items from a StreamWeave stream to standard output (stdout)
• StderrConsumer: Writes items from a StreamWeave stream to standard error (stderr)

Example

use streamweave_stdio::{StdinProducer, StdoutConsumer};
use streamweave::Pipeline;

let pipeline = Pipeline::new()
    .producer(StdinProducer::new())
    .transformer(/* ... */)
    .consumer(StdoutConsumer::new());

Re-exports

pub use consumers::*;

pub use producers::*;

Modules

consumers

Standard output (stdout) and standard error (stderr) consumers for StreamWeave

producers

Standard input (stdin) producer for StreamWeave