Struct PendingInbound 

struct PendingInbound<'a> {
    pair: Option<(FramedSendStream, FramedRecvStream)>,
    queue: &'a Mutex<VecDeque<(FramedSendStream, FramedRecvStream)>>,
}

Holds a peer-opened stream pair while its first message is being read, and puts it back on the connection’s queue if that read is abandoned.

Connection::accept_namespace_stream awaits a whole control message, and a caller may drop that future — a select! against a shutdown signal is the ordinary reason. Without this the stream, and every byte already read off it into the reader’s buffer, would go with the future: the peer would see its subscription reset for no reason it could act on.

Drop is the only place this can run, because a cancelled future is never polled again. Every path that finishes — success or error — takes the pair out first, so a pair still present when this drops was cancelled.

Fields

pair: Option<(FramedSendStream, FramedRecvStream)>

queue: &'a Mutex<VecDeque<(FramedSendStream, FramedRecvStream)>>

Trait Implementations

impl Drop for PendingInbound<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

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

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.