Enum InputEvent 

#[non_exhaustive]
pub enum InputEvent {
    PacketReceived(PacketReceived),
    AbortStreamsFrom(ParticipantIdentity),
    AbortAllStreams,
    QueryOpenStreamCount(Sender<usize>),
    Shutdown,
}

An event fed into [IncomingStreamManager::run] by the host crate. Each corresponds to an inbound data-stream packet (or a lifecycle signal) and carries everything the manager needs to process it without reaching back into room state.

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.

PacketReceived(PacketReceived)

AbortStreamsFrom(ParticipantIdentity)

Abort every open stream sent by this participant (they disconnected mid-send).

AbortAllStreams

Abort every open stream (e.g. the local connection is going away). Unlike InputEvent::Shutdown, the run loop keeps going so streams opened later are still handled.

QueryOpenStreamCount(Sender<usize>)

Reply with the number of currently open streams (registered by a header and awaiting more packets). Processed in order with the other events, so the answer reflects everything enqueued before it.

Shutdown

Stop the run loop, aborting every still-open stream as InputEvent::AbortAllStreams does.

Trait Implementations

impl From<PacketReceived> for InputEvent

Convert into PacketReceived variant.

fn from(v: PacketReceived) -> Self

Converts to this type from the input type.

impl From<ParticipantIdentity> for InputEvent

Convert into AbortStreamsFrom variant.

fn from(v: ParticipantIdentity) -> Self

Converts to this type from the input type.