Expand description

Extensions for OperatorBuilder to create async operators.


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


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


Extension trait for OperatorBuilder.