Struct RecvStream 

pub struct RecvStream {
    pub transport: Rc<WebTransport>,
    pub stream: WebTransportReceiveStream,
    pub reader: Reader,
    pub unlock_reader_on_drop: bool,
}

Recv the data from a WebTransport stream.

Fields

transport: Rc<WebTransport>

The WebTransport instance.

stream: WebTransportReceiveStream

The handle to the stream to read from.

reader: Reader

A reader to conduct the operation.

unlock_reader_on_drop: bool

Unlock the reader on drop.

Trait Implementations

impl AsyncRead for RecvStream

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl Drop for RecvStream

fn drop(&mut self)

Executes the destructor for this type.

impl Finished for RecvStream

type Error = Error

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

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

Wait for a stream to finish.

impl Read for RecvStream

type Error = StreamReadError

An error that can occur while reading the stream.

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

Read the data from the stream into a given buffer and return the amount of bytes filled in the buffer or None if the stream is closed and does not have any pending unread data.

impl ReadAbort for RecvStream

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 ReadAborted for RecvStream

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 write side to abort.