Module persist::operators::source [−][src]
Expand description
A Timely Dataflow operator that mirrors a persisted stream.
Traits
A Timely Dataflow operator that mirrors a persisted stream.
Functions
Creates a source that listens on the given listen_rx.