Trait differential_dataflow::capture::Writer

pub trait Writer<T> {
    fn poll(&mut self, item: &T) -> Option<Duration>;
    fn done(&self) -> bool;
}

A simple sink for byte slices.

Required methods

fn poll(&mut self, item: &T) -> Option<Duration>

Returns an amount of time to wait before retrying, or None for success.

fn done(&self) -> bool

Indicates if the sink has committed all sent data and can be safely dropped.

Loading content...

Implementors

Loading content...