Trait persist::operators::stream::AwaitFrontier

pub trait AwaitFrontier<G: Scope<Timestamp = u64>, D> {
    fn await_frontier(&self, name: &str) -> Stream<G, (D, u64, isize)>;
}

Extension trait for Stream.

Required methods

fn await_frontier(&self, name: &str) -> Stream<G, (D, u64, isize)>

Stashes data until it is no longer beyond the input frontier.

This is similar, in spirit, to what consolidate() does for differential collections and what delay() does for timely streams. However, consolidate() does more work than what we need and delay() deals with changing the timestamp while the behaviour we want is to wait for the frontier to pass. The latter is an implementation detail of delay() that is not advertised in its documentation. We therefore have our own implementation that we control to be sure we don’t break if delay() ever changes.

Implementations on Foreign Types

impl<G, D> AwaitFrontier<G, D> for Stream<G, (D, u64, isize)> where
    G: Scope<Timestamp = u64>,
    D: TimelyData, 

fn await_frontier(&self, name: &str) -> Stream<G, (D, u64, isize)>

Implementors