Function mz_timely_util::operator::source_async

pub fn source_async<G: Scope, CB, B, BFut>(
    scope: &G,
    name: String,
    constructor: B,
) -> StreamCore<G, CB::Container>
where
    CB: ContainerBuilder,
    B: FnOnce(Capability<G::Timestamp>, OperatorInfo, AsyncOutputHandle<G::Timestamp, CB, Tee<G::Timestamp, CB::Container>>) -> 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.