Struct timely::dataflow::operators::capture::event::binary::EventWriter

pub struct EventWriter<T, D, W: Write> { /* fields omitted */ }

A wrapper for W: Write implementing EventPusher<T, D>.

Methods

impl<T, D, W: Write> EventWriter<T, D, W>

fn new(w: W) -> EventWriter<T, D, W>

Allocates a new EventWriter wrapping a supplied writer.

Trait Implementations

impl<T: Abomonation, D: Abomonation, W: Write> EventPusher<T, D> for EventWriter<T, D, W>

fn push(&mut self, event: Event<T, D>)

Provides a new Event<T, D> to the pusher.