Module mz_timely_util::operators_async_ext
source · [−]Expand description
Extensions for OperatorBuilder
to create async operators.
Structs
The future returned by Scheduler::notified
A helper type to integrate timely notifications with async futures. Its intended to be used
with a top level while loop. Timely will automatically make the futures returned by
scheduler.notified.await()
resolve when there are progress or data updates to be processed by
the operatorEnums
Traits
Extension trait for
OperatorBuilder
.