Enum InputEvent 

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

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.

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.