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. |