Module timely::dataflow::operators::flow_controlled[][src]

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.