Skip to main content

StreamState

Struct StreamState 

Source
struct StreamState<'a> {
    stream_id: u64,
    key: StreamKey,
    is_control_stream: bool,
    pending: &'a mut PendingQueue,
    deferred: &'a mut DeferredEffects,
}
Expand description

The deferred-write state of one stream direction, plus the two facts every teardown helper needs about it.

Bundled because PendingQueue and DeferredEffects are only correct when they move together, and because propagate_reset needs both the stream’s identity and its queue.

Fields§

§stream_id: u64§key: StreamKey

This stream’s session-local identity, minted once at accept and carried to every site it reaches. Distinct from stream_id, which is the transport id and is 0 on every WebTransport stream.

§is_control_stream: bool

true selects the control-stream rules at Site::StreamEnd, where a synthesized reset is a session-level protocol violation and is refused rather than executed.

§pending: &'a mut PendingQueue§deferred: &'a mut DeferredEffects

Auto Trait Implementations§

§

impl<'a> !UnwindSafe for StreamState<'a>

§

impl<'a> Freeze for StreamState<'a>

§

impl<'a> RefUnwindSafe for StreamState<'a>

§

impl<'a> Send for StreamState<'a>

§

impl<'a> Sync for StreamState<'a>

§

impl<'a> Unpin for StreamState<'a>

§

impl<'a> UnsafeUnpin for StreamState<'a>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more