Module timely_util::operators_async_ext [−][src]
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 operator
Enums
Traits
Extension trait for OperatorBuilder
.