Function mz_timely_util::operator::source_async

pub fn source_async<G: Scope, C, B, BFut>(
    scope: &G,
    name: String,
    constructor: B
) -> StreamCore<G, C>
where
    C: Container,
    B: FnOnce(Capability<G::Timestamp>, OperatorInfo, AsyncOutputHandle<G::Timestamp, C, Tee<G::Timestamp, C>>) -> BFut,
    BFut: Future + 'static,

Creates a new async data stream source for a scope.

The source is defined by a name, and a constructor which takes a default capability and an output handle to a future. The future is then repeatedly scheduled, and is expected to eventually send data and downgrade and release capabilities.