Trait AsyncStreamWriter

pub trait AsyncStreamWriter {
    // Required methods
    fn write(&mut self, data: &[u8]) -> impl Future<Output = Result<()>>;
    fn write_bytes(&mut self, data: Bytes) -> impl Future<Output = Result<()>>;
    fn sync(&mut self) -> impl Future<Output = Result<()>>;
}

A non seekable writer, e.g. a network socket.

Required Methods

fn write(&mut self, data: &[u8]) -> impl Future<Output = Result<()>>

Write the entire slice.

In case of an error, some bytes may have been written.

fn write_bytes(&mut self, data: Bytes) -> impl Future<Output = Result<()>>

Write the entire bytes.

In case of an error, some bytes may have been written.

fn sync(&mut self) -> impl Future<Output = Result<()>>

Sync any buffers to the underlying storage.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl AsyncStreamWriter for Vec<u8>

async fn write(&mut self, data: &[u8]) -> Result<()>

async fn write_bytes(&mut self, data: Bytes) -> Result<()>

async fn sync(&mut self) -> Result<()>

impl AsyncStreamWriter for BytesMut

async fn write(&mut self, data: &[u8]) -> Result<()>

async fn write_bytes(&mut self, data: Bytes) -> Result<()>

async fn sync(&mut self) -> Result<()>

impl<T: AsyncStreamWriter> AsyncStreamWriter for &mut T

async fn write(&mut self, data: &[u8]) -> Result<()>

async fn sync(&mut self) -> Result<()>

async fn write_bytes(&mut self, data: Bytes) -> Result<()>

Implementors

impl<T: AsyncWrite + Unpin> AsyncStreamWriter for TokioStreamWriter<T>

impl<W: AsyncStreamWriter> AsyncStreamWriter for TrackingStreamWriter<W>