differential_dataflow::capture

Trait Writer

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

A simple sink for byte slices.

Required Methods§

Source

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

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

Source

fn done(&self) -> bool

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

Implementors§