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

A type that is not inhabited by any value. Should be redefined as the never type once it stabilizes

Traits

Extension trait for OperatorBuilder.