Module operators 

Extension traits for Stream and StreamVec implementing various operators.

A collection of functions taking typed stream objects as input and producing new stream objects as output. Many of the operators provide simple, composable functionality. Some of the operators are more complicated, for use with advanced timely dataflow features.

The core module defines operators that work for streams of general containers. The vec module defines operators that work for streams of vector containers.

The Operator trait provides general operators whose behavior can be supplied using closures accepting input and output handles. Most of the operators in this module are defined using these two general operators.

Re-exports

pub use self::inspect::Inspect;

pub use self::inspect::InspectCore;

pub use self::exchange::Exchange;

pub use self::generic::Operator;

pub use self::generic::Notificator;

pub use self::generic::FrontierNotificator;

pub use self::reclock::Reclock;

pub use self::core::enterleave;

pub use self::core::enterleave::Enter;

pub use self::core::enterleave::Leave;

pub use self::core::feedback;

pub use self::core::feedback::Feedback;

pub use self::core::feedback::LoopVariable;

pub use self::core::feedback::ConnectLoop;

pub use self::core::concat;

pub use self::core::concat::Concat;

pub use self::core::concat::Concatenate;

pub use self::core::inspect;

pub use self::core::exchange;

pub use self::core::probe;

pub use self::core::probe::Probe;

pub use self::core::capture;

pub use self::core::capture::Capture;

pub use self::core::ok_err;

pub use self::core::ok_err::OkErr;

pub use self::core::rc;

pub use self::core::to_stream::ToStream;

pub use self::core::input::Input;

pub use self::core::reclock;

Modules

core

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

generic

Generic operators defined by user-provided closures.

vec

Extension methods and implementations for streams of vector containers.

Structs

ActivateCapability

Capability that activates on drop or downgrade.

Capability

The capability to send data with a certain timestamp on a dataflow edge.

CapabilitySet

A set of capabilities, for possibly incomparable times.

DowngradeError

An error produced when trying to downgrade a capability with a time that’s not less than or equal to the current capability

InputCapability

An capability of an input port.

Traits

CapabilityTrait

An internal trait expressing the capability to send messages with a given timestamp.