Type Alias timely::dataflow::operators::capture::event::Event

pub type Event<T, D> = EventCore<T, Vec<D>>;

Data and progress events of the captured stream, specialized to vector-based containers.

Aliased Type

enum Event<T, D> {
    Progress(Vec<(T, i64)>),
    Messages(T, Vec<D>),
}

Variants

Progress(Vec<(T, i64)>)

Progress received via push_external_progress.

Messages(T, Vec<D>)

Messages received via the data stream.