Module timely::dataflow::channels

Structured communication between timely dataflow operators.

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.