Module core

Extension traits for StreamCore implementing various operators that are independent of specific container types.

Re-exports

pub use capture::Capture;

pub use concat::Concat;

pub use concat::Concatenate;

pub use enterleave::Enter;

pub use enterleave::Leave;

pub use exchange::Exchange;

pub use feedback::Feedback;

pub use feedback::LoopVariable;

pub use feedback::ConnectLoop;

pub use filter::Filter;

pub use input::Input;

pub use inspect::Inspect;

pub use inspect::InspectCore;

pub use map::Map;

pub use ok_err::OkErr;

pub use partition::Partition;

pub use probe::Probe;

pub use to_stream::ToStream;

pub use to_stream::ToStreamBuilder;

pub use reclock::Reclock;

pub use unordered_input::UnorderedInput;

pub use unordered_input::UnorderedHandle;

Modules

capture

Operators to capture and replay timely dataflow streams.

concat

Merges the contents of multiple streams.

enterleave

Extension traits to move a Stream between an outer Scope and inner Scope.

exchange

Exchange records between workers.

feedback

Create cycles in a timely dataflow graph.

filter

Filters a stream by a predicate.

input

Create new Streams connected to external inputs.

inspect

Extension trait and implementation for observing and action on streamed data.

map

Extension methods for StreamCore based on record-by-record transformation.

ok_err

Operators that separate one stream into two streams based on some condition

partition

Partition a stream of records into multiple streams.

probe

Monitor progress at a Stream.

rc

Shared containers

reclock

Extension methods for Stream based on record-by-record transformation.

to_stream

Conversion to the StreamCore type from iterators.

unordered_input

Create new StreamCores connected to external inputs.