Module channels 

Structured communication between timely dataflow operators.

Re-exports

pub use crate::progress::Stamp;

Modules

pact

Parallelization contracts, describing how data must be exchanged between operators. Parallelization contracts, describing requirements for data movement along dataflow edges.

pullers

A collection of types that may be pulled from.

pushers

A collection of types that may be pushed at.

Structs

Message

A serializable representation of timestamped data.

Traits

ContainerBytes

A container-oriented version of Bytesable that can be implemented here for Vec<T> and other containers.