Skip to main content

StreamingSink

datasynth_core::traits

Trait StreamingSink 

Source 
pub trait StreamingSink<T>: Send {
    // Required methods
    fn process(&mut self, event: StreamEvent<T>) -> SynthResult<()>;
    fn flush(&mut self) -> SynthResult<()>;
    fn close(self) -> SynthResult<()>;
    fn items_processed(&self) -> u64;
}
Expand description

Trait for output sinks that support streaming input.

Required Methods§

Source

fn process(&mut self, event: StreamEvent<T>) -> SynthResult<()>

Processes a stream event.

Source

fn flush(&mut self) -> SynthResult<()>

Flushes any buffered data.

Source

fn close(self) -> SynthResult<()>

Closes the sink and releases resources.

Source

fn items_processed(&self) -> u64

Returns the number of items processed.

Implementors§