Skip to main content

StreamEvent

Enum StreamEvent

pub enum StreamEvent {
    Opened {
        id: StreamId,
    },
    Readable {
        id: StreamId,
    },
    Writable {
        id: StreamId,
    },
    Finished {
        id: StreamId,
    },
    Stopped {
        id: StreamId,
        error_code: ErrorCauseCode,
    },
    Available,
    BufferedAmountLow {
        id: StreamId,
    },
    BufferedAmountHigh {
        id: StreamId,
    },
}

Expand description

Application events about streams

Variants§

Opened

One or more new streams has been opened

Fields

§id: StreamId

Readable

A currently open stream has data or errors waiting to be read

Fields

§id: StreamId

Which stream is now readable

Writable

A formerly write-blocked stream might be ready for a write or have been stopped

Only generated for streams that are currently open.

Fields

§id: StreamId

Which stream is now writable

Finished

A finished stream has been fully acknowledged or stopped

Fields

§id: StreamId

Which stream has been finished

Stopped

The peer asked us to stop sending on an outgoing stream

Fields

§id: StreamId

Which stream has been stopped

§error_code: ErrorCauseCode

Error code supplied by the peer

Available

At least one new stream of a certain directionality may be opened

BufferedAmountLow

The number of bytes of outgoing data buffered is lower than the threshold.

Fields

§id: StreamId

Which stream is now readable

BufferedAmountHigh

The number of bytes of outgoing data buffered is higher than the threshold.

Fields

§id: StreamId

Which stream is now readable

Trait Implementations§

impl Debug for StreamEvent

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

Formats the value using the given formatter. Read more

impl Eq for StreamEvent

impl PartialEq for StreamEvent

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

Tests for self and other values to be equal, and is used by ==.

1.0.0 (const: unstable) · Source§

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for StreamEvent

Auto Trait Implementations§

impl Freeze for StreamEvent

impl RefUnwindSafe for StreamEvent

impl Send for StreamEvent

impl Sync for StreamEvent

impl Unpin for StreamEvent

impl UnsafeUnpin for StreamEvent

impl UnwindSafe for StreamEvent

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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

fn into(self) -> U

Calls U::from(self).

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

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> Same for T

type Output = T

Should always be Self

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

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V