Struct ArunaStreamReadWriter 

pub struct ArunaStreamReadWriter<'a, R: Stream<Item = Result<Bytes, Box<dyn Error + Send + Sync + 'static>>> + Unpin + Send + Sync> { /* private fields */ }

Implementations

impl<'a, R: Stream<Item = Result<Bytes, Box<dyn Error + Send + Sync + 'static>>> + Unpin + Send + Sync> ArunaStreamReadWriter<'a, R>

pub fn new_with_sink<T: Transformer + Sink + Send + Sync + 'a>( input_stream: R, transformer: T, ) -> Self

pub fn new_with_writer<W: AsyncWrite + Send + Sync + 'a>( input_stream: R, writer: W, ) -> Self

pub fn add_transformer<T: Transformer + Send + Sync + 'a>( self, transformer: T, ) -> ArunaStreamReadWriter<'a, R>

Trait Implementations

impl<'a, R: Stream<Item = Result<Bytes, Box<dyn Error + Send + Sync + 'static>>> + Unpin + Send + Sync> ReadWriter for ArunaStreamReadWriter<'a, R>

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

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

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

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

fn add_file_context_receiver<'life0, 'async_trait>( &'life0 mut self, rx: Receiver<(FileContext, bool)>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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