Struct RecvStream 

#[repr(transparent)]
pub struct RecvStream<T>(pub T);

A WebTransport recv-stream.

Tuple Fields

0: T

Implementations

impl<T> RecvStream<T>

pub const fn from_const(value: T) -> Self

Create an instance from a value of the underlying type T with a const context.

pub fn into_inner(self) -> T

Take the underlying value out.

pub const fn inner_ref(&self) -> &T

Take a ref to the underlying value.

pub fn inner_mut(&mut self) -> &mut T

Take a mut ref to the underlying value.

Trait Implementations

impl<T> AsMut<T> for RecvStream<T>

fn as_mut(&mut self) -> &mut T

Converts this type into a mutable reference of the (usually inferred) input type.

impl<T> AsRef<T> for RecvStream<T>

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.

impl<T> Deref for RecvStream<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> DerefMut for RecvStream<T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T> Finished for RecvStream<T>

where T: Finished,

type Error = <T as Finished>::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<T> From<T> for RecvStream<T>

fn from(value: T) -> Self

Converts to this type from the input type.

impl<T> Read for RecvStream<T>

where T: Read,

type Error = <T as Read>::Error

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<T> ReadAbort for RecvStream<T>

where T: ReadAbort,

type Error = <T as ReadAbort>::Error

An error that can occur while stopping the stream.

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

Abort the stream.

impl<T> ReadAborted for RecvStream<T>

where T: ReadAborted,

type Error = <T as ReadAborted>::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.