Struct libp2prs_secio::codec::secure_stream::SecureStreamWriter

pub struct SecureStreamWriter<W> { /* fields omitted */ }

SecureStreamWriter

Trait Implementations

impl<W> WriteEx for SecureStreamWriter<W> where
    W: WriteEx + 'static, 

fn write2<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    buf: &'life1 [u8]
) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Attempt to write bytes from buf into the object.

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

Attempt to flush the object, ensuring that any buffered data reach their destination.

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

Attempt to close the object.

#[must_use]pub fn write_all2<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    buf: &'life1 [u8]
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Attempt to write the entire contents of data into object.

#[must_use]pub fn write_varint<'life0, 'async_trait>(
    &'life0 mut self,
    len: usize
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Writes a variable-length integer to the underlying IO.

#[must_use]pub fn write_fixed_u32<'life0, 'async_trait>(
    &'life0 mut self,
    len: usize
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Writes a fixed-length integer to the underlying IO.

#[must_use]pub fn write_one_fixed<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    buf: &'life1 [u8]
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Send a fixed length message to the underlying IO, then flushes the writing side.

#[must_use]pub fn write_one<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    buf: &'life1 [u8]
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Send a variable length message to the underlying IO, then flushes the writing side.