Struct ArunaReadWriter 

pub struct ArunaReadWriter<'a, R: AsyncRead + Unpin> { /* private fields */ }

Implementations

impl<'a, R: AsyncRead + Unpin> ArunaReadWriter<'a, R>

pub fn new_with_writer<W: AsyncWrite + Unpin + Send + Sync + 'a>( reader: R, writer: W, ) -> ArunaReadWriter<'a, R>

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

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

Trait Implementations

impl<'a, R: AsyncRead + Unpin + Send + Sync> ReadWriter for ArunaReadWriter<'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,