Struct CollectionSink

pub struct CollectionSink<T> { /* private fields */ }

A sink that collects elements into a Vec

Implementations

impl<T> CollectionSink<T>

pub fn new() -> Self

pub fn get_data(&self) -> Vec<T>

where T: Clone,

Trait Implementations

impl<T: Clone> Clone for CollectionSink<T>

fn clone(&self) -> CollectionSink<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Default> Default for CollectionSink<T>

fn default() -> CollectionSink<T>

Returns the “default value” for a type.

impl<T> Sink<T> for CollectionSink<T>

where T: Clone + Send + Sync + 'static,

fn init<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initialize the sink

fn write<'life0, 'async_trait>( &'life0 mut self, record: Record<T>, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Write a record to the sink

fn flush<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flush any buffered data

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the sink and release resources