Trait AsyncWriteExt

Source

pub trait AsyncWriteExt: AsyncWrite {
Show 30 methods    // Provided methods
    fn by_ref(&mut self) -> &mut Self
       where Self: Sized { ... }
    async fn write_all<T: IoBuf>(&mut self, buf: T) -> BufResult<(), T> { ... }
    async fn write_vectored_all<T: IoVectoredBuf>(
        &mut self,
        buf: T,
    ) -> BufResult<(), T> { ... }
    fn framed<T, C, F>(
        self,
        codec: C,
        framer: F,
    ) -> Framed<Self::ReadHalf, Self::WriteHalf, C, F, T, T>
       where Self: Splittable + Sized { ... }
    fn bytes(self) -> BytesFramed<Self::ReadHalf, Self::WriteHalf>
       where Self: Splittable + Sized { ... }
    fn write_only(self) -> WriteOnly<Self>
       where Self: Sized { ... }
    async fn write_u8(&mut self, num: u8) -> Result<()> { ... }
    async fn write_u8_le(&mut self, num: u8) -> Result<()> { ... }
    async fn write_u16(&mut self, num: u16) -> Result<()> { ... }
    async fn write_u16_le(&mut self, num: u16) -> Result<()> { ... }
    async fn write_u32(&mut self, num: u32) -> Result<()> { ... }
    async fn write_u32_le(&mut self, num: u32) -> Result<()> { ... }
    async fn write_u64(&mut self, num: u64) -> Result<()> { ... }
    async fn write_u64_le(&mut self, num: u64) -> Result<()> { ... }
    async fn write_u128(&mut self, num: u128) -> Result<()> { ... }
    async fn write_u128_le(&mut self, num: u128) -> Result<()> { ... }
    async fn write_i8(&mut self, num: i8) -> Result<()> { ... }
    async fn write_i8_le(&mut self, num: i8) -> Result<()> { ... }
    async fn write_i16(&mut self, num: i16) -> Result<()> { ... }
    async fn write_i16_le(&mut self, num: i16) -> Result<()> { ... }
    async fn write_i32(&mut self, num: i32) -> Result<()> { ... }
    async fn write_i32_le(&mut self, num: i32) -> Result<()> { ... }
    async fn write_i64(&mut self, num: i64) -> Result<()> { ... }
    async fn write_i64_le(&mut self, num: i64) -> Result<()> { ... }
    async fn write_i128(&mut self, num: i128) -> Result<()> { ... }
    async fn write_i128_le(&mut self, num: i128) -> Result<()> { ... }
    async fn write_f32(&mut self, num: f32) -> Result<()> { ... }
    async fn write_f32_le(&mut self, num: f32) -> Result<()> { ... }
    async fn write_f64(&mut self, num: f64) -> Result<()> { ... }
    async fn write_f64_le(&mut self, num: f64) -> Result<()> { ... }
}

Expand description

Implemented as an extension trait, adding utility methods to all AsyncWrite types. Callers will tend to import this trait instead of AsyncWrite.

Provided Methods§

Source

fn by_ref(&mut self) -> &mut Self
where Self: Sized,

Creates a “by reference” adaptor for this instance of AsyncWrite.

The returned adapter also implements AsyncWrite and will simply borrow this current writer.

Source

async fn write_all<T: IoBuf>(&mut self, buf: T) -> BufResult<(), T>

Write the entire contents of a buffer into this writer.

Source

async fn write_vectored_all<T: IoVectoredBuf>( &mut self, buf: T, ) -> BufResult<(), T>

Write the entire contents of a buffer into this writer. Like AsyncWrite::write_vectored, except that it tries to write the entire contents of the buffer into this writer.

Source

fn framed<T, C, F>( self, codec: C, framer: F, ) -> Framed<Self::ReadHalf, Self::WriteHalf, C, F, T, T>
where Self: Splittable + Sized,

Create a framed::Framed reader/writer with the given codec and framer.

Source

fn bytes(self) -> BytesFramed<Self::ReadHalf, Self::WriteHalf>
where Self: Splittable + Sized,

Available on crate feature bytes only.

Convenience method to create a framed::BytesFramed reader/writer out of a splittable.

Source

fn write_only(self) -> WriteOnly<Self>
where Self: Sized,

Create a Splittable that uses Self as WriteHalf and () as ReadHalf.

This is useful for creating framed sink with only a writer, using the AsyncWriteExt::framed or AsyncWriteExt::bytes method, which require a Splittable to work.

§Examples

use compio_io::{AsyncWriteExt, framed::BytesFramed};

let mut file_bytes = file.write_only().bytes();
file_bytes.send(Bytes::from("hello world")).await?;

Source