Function persist::operators::source::listen_source

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, 

Creates a source that listens on the given listen_rx.