Enum timely::dataflow::operators::capture::event::Event

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

Data and progress events of the captured stream.

Variants

Progress(Vec<(T, i64)>)

Progress received via push_external_progress.

Messages(T, Vec<D>)

Messages received via the data stream.

Trait Implementations

impl<T: Debug, D: Debug> Debug for Event<T, D>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T: Clone, D: Clone> Clone for Event<T, D>

fn clone(&self) -> Event<T, D>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Abomonation, D: Abomonation> Abomonation for Event<T, D>

unsafe fn entomb<W: Write>(&self, write: &mut W) -> Result<()>

Write any additional information about &self beyond its binary representation.

unsafe fn exhume<'a, 'b>(
    &'a mut self,
    bytes: &'b mut [u8]
) -> Option<&'b mut [u8]>

Recover any information for &mut self not evident from its binary representation.

fn extent(&self) -> usize

Reports the number of further bytes required to entomb self.