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: Abomonation, D: Abomonation> Abomonation for Event<T, D>

unsafe fn embalm(&mut self)

Perform any final edits before committing &mut self. Importantly, this method should only manipulate the fields of self; any owned memory may not be valid.

unsafe fn entomb(&self, bytes: &mut Vec<u8>)

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.