Struct xwt_web_sys::Session

pub struct Session {
    pub transport: Rc<WebTransport>,
    pub datagram_readable_stream_reader: ReadableStreamByobReader,
    pub datagram_writable_stream_writer: WritableStreamDefaultWriter,
    pub datagram_read_buffer_size: u32,
    pub datagram_read_buffer: Mutex<Option<ArrayBuffer>>,
}

Session holds the sys::WebTransport and is responsible for providing access to the Web API of WebTransport in a way that is portable. It also holds handles to the datagram reader and writer, as well as the datagram reader state.

Fields

transport: Rc<WebTransport>

The WebTransport instance.

datagram_readable_stream_reader: ReadableStreamByobReader

The datagram reader.

datagram_writable_stream_writer: WritableStreamDefaultWriter

The datagram writer.

datagram_read_buffer_size: u32

The desired size of the datagram read buffer. Used to allocate the datagram read buffer in case it gets lost.

datagram_read_buffer: Mutex<Option<ArrayBuffer>>

The datagram read internal buffer.

Implementations

impl Session

pub async fn receive_datagram_with<R>( &self, f: impl FnOnce(&mut Uint8Array) -> R ) -> Result<R, Error>

Receive the datagram and handle the buffer with the given function.

Cloning the buffer in the f will result in the undefined behaviour, becaue it will create a second reference to an object that is inteded to be under a mut ref. Althoug is would not teachnically be unsafe, it would violate the borrow checker rules.

Trait Implementations

impl AcceptBi for Session

type Error = Error

async fn accept_bi( &self ) -> Result<(Self::SendStream, Self::RecvStream), Self::Error>

impl AcceptUni for Session

type Error = Error

async fn accept_uni(&self) -> Result<Self::RecvStream, Self::Error>

impl Debug for Session

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Session

fn drop(&mut self)

Executes the destructor for this type.

impl OpenBi for Session

type Opening = OpeningBiStream<Session>

type Error = Error

async fn open_bi(&self) -> Result<Self::Opening, Self::Error>

impl OpenUni for Session

type Opening = OpeningUniStream<Session>

type Error = Error

async fn open_uni(&self) -> Result<Self::Opening, Self::Error>

impl Receive for Session

type Datagram = Vec<u8>

type Error = Error

async fn receive_datagram(&self) -> Result<Self::Datagram, Self::Error>

impl ReceiveInto for Session

type Error = Error

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

impl RecvSpec for Session

type RecvStream = RecvStream

impl Send for Session

type Error = Error

async fn send_datagram<D>(&self, payload: D) -> Result<(), Self::Error>

where D: AsRef<[u8]>,

impl SendSpec for Session

type SendStream = SendStream