Struct Outgoing 

pub struct Outgoing { /* private fields */ }

Outgoing framed stream

Implementations

impl Outgoing

pub fn new<T, Fut>( tx: T, on_egress: impl FnOnce(T, Result<()>) -> Fut + Send + 'static, ) -> Self

where T: AsyncWrite + Unpin + Send + 'static, Fut: Future<Output = ()> + Send,

Creates a new Outgoing given an AsyncWrite.

pub fn index(&self, path: &[usize]) -> Result<Self>

Index the outgoing stream using a structural path, returning a handle that writes to the multiplexed sub-stream addressed by it.

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

Writes buf to the stream as a single frame, without copying it.

Trait Implementations

impl AsyncWrite for Outgoing

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

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

fn poll_shutdown( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Index for Outgoing

fn index(&self, path: &[usize]) -> Result<Self>

Index the entity using a structural path

impl Sink for Outgoing

async fn write_future<T>( self, _offset: usize, item: impl Future<Output = T> + Send + 'static, ) -> Result<()>

where T: Encode<Self>, Error: From<<T::Encoder as Encoder<T>>::Error>,

Transmits the value of a future<T>

async fn write_stream<T>( self, _offset: usize, items: impl Stream<Item = Vec<T>> + Send + Unpin + 'static, ) -> Result<()>

where T: Encode<Self> + Send + 'static, Error: From<<T::Encoder as Encoder<T>>::Error>,

Transmits the elements of a stream<T>

async fn write_stream_bytes( self, _offset: usize, items: impl Stream<Item = Bytes> + Send + Unpin + 'static, ) -> Result<()>

Transmits the elements of a stream<u8> from a Stream of Bytes

async fn write_stream_read( self, _offset: usize, buf: BytesMut, items: impl AsyncRead + Send + Unpin + 'static, ) -> Result<()>

Transmits the elements of a stream<u8> from ready followed by an AsyncRead