Crate rskit_pipeline 

Composable async data pipelines built on futures::Stream.

Re-exports

pub use broadcaster::BroadcastStream;

pub use broadcaster::Broadcaster;

pub use broadcaster::DEFAULT_BROADCAST_BUFFER;

pub use executor::Step;

pub use executor::StepExecutor;

pub use executor::StepStatus;

pub use ext::RskitStreamExt;

pub use operators::combine::concat;

pub use operators::combine::merge;

pub use sink::collect;

pub use sink::drain;

pub use sink::for_each;

pub use source::from_channel;

pub use source::from_fn;

pub use source::from_slice;

Modules

broadcaster

Bounded fan-out broadcaster source (Broadcaster<T>). Bounded fan-out broadcaster source.

executor

Sequential step-based executor with progress and cancellation. Sequential step-based executor with progress reporting and cancellation.

ext

Extension trait adding rskit operators to any Stream. RskitStreamExt — ergonomic extension methods on futures::Stream.

operators

Higher-level stream operators (map, filter, fan-out, windowing, etc.).

sink

Terminal sink combinators (collect, drain, for_each).

source

Stream source constructors (from_slice, from_fn, from_channel).