Struct ChannelSink 

pub struct ChannelSink { /* private fields */ }

A channel-based stream sink.

Implementations

impl ChannelSink

pub fn new(sender: Sender<StreamMessage>) -> Self

Create a new channel sink.

pub fn with_buffer_size( sender: Sender<StreamMessage>, buffer_size: usize, ) -> Self

Create a new channel sink with a custom buffer size.

Trait Implementations

impl StreamSink for ChannelSink

fn write<'life0, 'async_trait>( &'life0 mut self, element: StreamMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Write an element to the sink.

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

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

Flush buffered elements.

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

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

Close the sink.