Enum StreamError 

#[non_exhaustive]
pub enum StreamError {
    Session(SessionError),
    Internal,
    Cancel,
    DeliveryTimeout,
    ControlTimeout,
    GoingAway,
    TooFarBehind,
    MalformedTrack,
    NotFound,
    Unroutable,
    Old,
    Evicted,
    WrongSize,
    FrameTooLarge,
    GroupTooLarge,
    TimestampMismatch,
    App(u16),
    Unknown(u32),
}

A code sent when resetting a stream, or refusing to receive one.

The counterpart to SessionError, and a disjoint space: a stream reset of 0 is Internal, not a cancellation (Cancel is 1).

Conditions the shared codes don’t cover are assigned in moq-lite’s own 48-63 range and round-trip like any other registered code. 32 through 47 is reserved: nothing is sent there and a received one stays Unknown.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Session(SessionError)

The session ended, taking this stream with it.

The specific SessionError is local only: the two registries are disjoint, so this encodes to a single SESSION_CLOSED and the peer learns the reason from the session close itself.

Internal

Something went wrong that isn’t worth a dedicated code.

Cancel

The sender is done with this stream, not failing. A routine unsubscribe.

DeliveryTimeout

The content missed its delivery deadline.

ControlTimeout

A control request took too long to be answered. The stream counterpart to SessionError::Timeout, which covers the same condition at session scope.

GoingAway

The session is going away (a GOAWAY was received).

TooFarBehind

The reader fell too far behind and content was dropped to catch up.

MalformedTrack

The track’s content could not be parsed.

NotFound

The requested broadcast or track does not exist at the peer.

Unroutable

The broadcast is neither announced nor served, so there is no route to it.

Old

The group was superseded by a newer group and dropped.

Evicted

The group was dropped under memory pressure. Unlike Old it was still current, so it can be re-fetched.

WrongSize

A frame’s payload length disagreed with its declared size.

FrameTooLarge

A frame declared a payload larger than the receiver accepts.

GroupTooLarge

A group grew past its cache budget and was aborted.

TimestampMismatch

A frame’s timestamp doesn’t match its track’s negotiated timescale.

App(u16)

An application-chosen code, offset into the 64+ range on the wire.

Unknown(u32)

A code this version does not recognize, kept verbatim.

Implementations

impl StreamError

pub fn to_code(&self) -> u32

The integer sent on the wire.

pub fn from_code(code: u32) -> Self

Decode a code received off the wire.

Only the registered codes decode; anything else, the reserved 32-47 range included, stays Unknown rather than being given a meaning the draft does not assign.

SESSION_CLOSED decodes to Session(SessionError::Internal): the peer’s actual session code is not on this stream, so the specific reason is unknown here.

Trait Implementations

impl Clone for StreamError

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamError

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

Formats the value using the given formatter.

impl Display for StreamError

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

Formats the value using the given formatter.

impl Eq for StreamError

impl Error for StreamError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl From<&Error> for StreamError

Which stream code to send for a local error.

Session-scoped conditions route through StreamError::Session, which flattens to SESSION_CLOSED on the wire.

fn from(err: &Error) -> Self

Converts to this type from the input type.

impl From<SessionError> for StreamError

fn from(source: SessionError) -> Self

Converts to this type from the input type.

impl From<StreamError> for Error

Preserve the stream registry when carrying a protocol error.

fn from(err: StreamError) -> Self

Converts to this type from the input type.

impl PartialEq for StreamError

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StreamError