Struct SendStream 

pub struct SendStream {
    pub transport: Rc<WebTransport>,
    pub stream: WebTransportSendStream,
    pub writer: Writer,
    pub unlock_writer_on_drop: bool,
}

Send the data into a WebTransport stream.

Fields

transport: Rc<WebTransport>

The WebTransport instance.

stream: WebTransportSendStream

The handle to the stream to write to.

writer: Writer

A writer to conduct the operation.

unlock_writer_on_drop: bool

Unlock the writer on drop.

Trait Implementations

impl AsyncWrite for SendStream

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

Attempt to write bytes from buf into the object.

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

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<(), Error>>

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

fn drop(&mut self)

Executes the destructor for this type.

impl Finish for SendStream

type Error = Error

An error that can occur while finishing the stream.

async fn finish(self) -> Result<(), Self::Error>

Finish the stream.

impl Write for SendStream

type Error = StreamWriteError

An error that can occur while writing to the stream.

async fn write(&mut self, buf: &[u8]) -> Result<NonZeroUsize, Self::Error>

Write the data from the given buffer into the stream, returning the amount of of bytes that were successfully written into the stream. If the returned amount is smaller than the size of the data that was being written, the user should try writing the remaining data again.

impl WriteAbort for SendStream

type Error = Error

An error that can occur while stopping the stream.

async fn abort(self, error_code: ErrorCode) -> Result<(), Self::Error>

Abort the stream.

impl WriteAborted for SendStream

type Error = Error

An error that can occur while waiting for a stream to be aborted.

async fn aborted(self) -> Result<ErrorCode, Self::Error>

Wait for a stream’s corresponding read side to abort.