Trait SendStream

pub trait SendStream: Send {
    // Required methods
    fn send_bytes(
        &mut self,
        bytes: Bytes,
    ) -> impl Future<Output = Result<()>> + Send;
    fn send<const L: usize>(
        &mut self,
        buf: &[u8; L],
    ) -> impl Future<Output = Result<()>> + Send;
    fn sync(&mut self) -> impl Future<Output = Result<()>> + Send;
    fn reset(&mut self, code: VarInt) -> Result<()>;
    fn stopped(&mut self) -> impl Future<Output = Result<Option<VarInt>>> + Send;
}

An abstract iroh::endpoint::SendStream.

Required Methods

fn send_bytes( &mut self, bytes: Bytes, ) -> impl Future<Output = Result<()>> + Send

Send bytes to the stream. This takes a Bytes because iroh can directly use them.

fn send<const L: usize>( &mut self, buf: &[u8; L], ) -> impl Future<Output = Result<()>> + Send

Send that sends a fixed sized buffer.

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

Sync the stream. Not needed for iroh, but needed for intermediate buffered streams such as compression.

fn reset(&mut self, code: VarInt) -> Result<()>

Reset the stream with the given error code.

fn stopped(&mut self) -> impl Future<Output = Result<Option<VarInt>>> + Send

Wait for the stream to be stopped, returning the error code if it was.

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 SendStream for SendStream

async fn send_bytes(&mut self, bytes: Bytes) -> Result<()>

async fn send<const L: usize>(&mut self, buf: &[u8; L]) -> Result<()>

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

fn reset(&mut self, code: VarInt) -> Result<()>

async fn stopped(&mut self) -> Result<Option<VarInt>>

impl<W: SendStream> SendStream for &mut W

async fn send_bytes(&mut self, bytes: Bytes) -> Result<()>

async fn send<const L: usize>(&mut self, buf: &[u8; L]) -> Result<()>

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

fn reset(&mut self, code: VarInt) -> Result<()>

async fn stopped(&mut self) -> Result<Option<VarInt>>

Implementors

impl<W: SendStreamSpecific> SendStream for AsyncWriteSendStream<W>