Module timely::dataflow::operators::flow_controlled

Methods to construct flow-controlled sources.

Structs

• IteratorSourceInput
  Output of the input reading function for iterator_source.

Functions

• iterator_source
  Construct a source that repeatedly calls the provided function to ingest input.