Skip to main content

StreamEvent

Enum StreamEvent 

Source
#[non_exhaustive]
pub enum StreamEvent { Opened { id: StreamId, }, Readable { id: StreamId, }, Writable { id: StreamId, }, Finished { id: StreamId, }, ResetComplete { id: StreamId, }, ResetFailed { id: StreamId, reason: StreamResetError, }, Stopped { id: StreamId, error_code: ErrorCauseCode, }, Available, BufferedAmountLow { id: StreamId, }, BufferedAmountHigh { id: StreamId, }, }
Expand description

Application events about streams

Variants (Non-exhaustive)§

This enum is marked as 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.
§

Opened

One or more new streams has been opened

Fields

§id: StreamId

Which stream was opened

§

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

The stream was torn down by a reset, an inbound reset request from the peer naming the id was processed or its reciprocal to a locally-initiated one.

No more data can be read from or written to it.

Once this fires, either StreamEvent::ResetComplete or StreamEvent::ResetFailed for the same id is guaranteed to eventually follow, unless the association closes first.

Fields

§id: StreamId

Which stream has been finished

§

ResetComplete

A reset handshake involving this stream id completed successfully.

The id can be reused unless a newer reset for the same id has since started or failed.

Fields

§id: StreamId

Which stream id completed its reset.

§

ResetFailed

A reset handshake involving this stream id did not complete.

The id remains unavailable for reuse until a later reset succeeds or the association closes.

Fields

§id: StreamId

Which stream id failed to reset.

§reason: StreamResetError

Why the reset did not complete.

§

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 has crossed the high threshold

Trait Implementations§

Source§

impl Debug for StreamEvent

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Eq for StreamEvent

Source§

impl PartialEq for StreamEvent

Source§

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

Equality operator ==. Read more
1.0.0 (const: unstable) · Source§

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

Inequality operator !=. Read more
Source§

impl StructuralPartialEq for StreamEvent

Auto Trait Implementations§

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.

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 = Infallible

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

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

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.
Source§

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

Source§

fn vzip(self) -> V