Struct xwt_web_sys::SendStream

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

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.

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

type Error = Error

An error that can occur while writing to the stream.

async fn write(&mut self, buf: &[u8]) -> Result<usize, 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 remainig data again.