Trait iroh_io::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.

Object Safety

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>