Enum MuxPoll 

pub enum MuxPoll {
    NeedMoreBytes,
    Legacy,
    ProbeAnswered {
        reply: Vec<u8>,
        consumed: usize,
    },
    Payload {
        frame: Frame,
        consumed: usize,
    },
}

What the daemon’s accept loop should do with its buffered bytes.

Variants

NeedMoreBytes

Not enough bytes to classify or to complete a frame. Read more bytes into the buffer and poll again. Nothing is consumed.

Legacy

The buffer starts a legacy-wire message. Nothing is consumed; hand the buffer to the daemon’s legacy decoder.

ProbeAnswered

A BackendHandle identity probe was answered. Write reply to the peer verbatim, then advance the read buffer by consumed.

Fields

reply: Vec<u8>

Complete wire bytes ([1][len][prost Frame]) to send back.

consumed: usize

Bytes of the probe request to consume from the buffer front.

Payload

A consumer payload frame arrived. Dispatch frame.payload through the daemon’s request handler (correlate on frame.request_id), then advance the read buffer by consumed.

Fields

frame: Frame

The decoded consumer frame (kind, payload protocol, payload, request id, trace context).

consumed: usize

Bytes the frame occupied; consume from the buffer front.

Trait Implementations

impl Debug for MuxPoll

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.