Struct ControlLeg 

pub(crate) struct ControlLeg {
    pub(crate) inbox: Sender<StreamCommand>,
    pub(crate) requests: Receiver<StreamCommand>,
}

The two ends of one control-stream direction’s request channel.

Created in the session’s run function, before the control stream exists, so that the sending half can go into the control-plane registry at the same moment as the rest of the session’s entry. An injection that arrives before the control stream has been established waits in this channel rather than being refused — the session is live, and there will be a stream.

Fields

inbox: Sender<StreamCommand>

Where a request for this direction is delivered.

requests: Receiver<StreamCommand>

What the direction’s pipe serves.

Implementations

impl ControlLeg

pub(crate) fn new() -> Self

A fresh channel for one control-stream direction.