Function persist::operators::source::listen_source [−][src]
fn listen_source<G, K, V>(
scope: &G,
initial_frontier: Option<Antichain<u64>>,
listen_rx: Receiver<ListenEvent>
) -> Stream<G, (Result<(K, V), String>, u64, isize)> where
G: Scope<Timestamp = u64>,
K: TimelyData + Codec + Send,
V: TimelyData + Codec + Send,
Expand description
Creates a source that listens on the given listen_rx
.