Struct Multiplexer 

pub struct Multiplexer {
    SideCarIdentifier: String,
    Sink: Sender<Envelope>,
    Pending: Arc<DashMap<u64, Sender<GenericResponse>>>,
    NextRequestIdentifier: AtomicU64,
    Closed: AtomicBool,
}

One multiplexer per sidecar connection. Holds the outbound sink, the pending-request correlation map, and a shared-state shutdown flag.

Fields

SideCarIdentifier: String

Sink: Sender<Envelope>

Pending: Arc<DashMap<u64, Sender<GenericResponse>>>

NextRequestIdentifier: AtomicU64

Closed: AtomicBool

Implementations

impl Multiplexer

pub async fn Open( SideCarIdentifier: String, Client: CocoonServiceClient<Channel>, ) -> Result<Arc<Self>, VineError>

Open a bidirectional streaming channel against an existing CocoonServiceClient. Spawns the read pump as a detached tokio task and registers the multiplexer in the global registry. Returns once the stream is established.

pub fn Lookup(SideCarIdentifier: &str) -> Option<Arc<Self>>

Look up the multiplexer for a sidecar. Returns None if no streaming connection has been opened for that sidecar (the caller should fall back to the unary path).

pub fn Deregister(SideCarIdentifier: &str)

Drop the registry entry. Called by the read-pump when the stream closes.

pub async fn Notify( &self, Method: String, Parameters: Value, ) -> Result<(), VineError>

Send a notification frame (fire-and-forget). Non-blocking modulo Sink backpressure (capacity SINK_CAPACITY).

pub async fn Request( &self, Method: String, Parameters: Value, Timeout: Duration, ) -> Result<Value, VineError>

Send a request and await the matching response. Cancels the pending entry on timeout. The future is Send + 'static-clean so callers can drive it inside tokio::select! for finer- grained cancellation.

pub async fn Cancel(&self, RequestIdentifier: u64) -> Result<(), VineError>

Send a Cancel frame asking the peer to abort an in-flight request matching RequestIdentifier. Best-effort; the peer chooses whether to honour it.

pub fn IsClosed(&self) -> bool

pub fn SideCarIdentifierBorrow(&self) -> &str