Struct WireHandoffDelivery 

pub struct WireHandoffDelivery<S> { /* private fields */ }

HandoffDelivery implementation that sends HandoffOffer frames to the backend over a framed control connection and waits for the matching HandoffAck.

deliver writes one offer frame; await_backend_ack reads one response frame and requires the token echo, the correlation id, and the accepted flag to all match. Every violation is a delivery error — the orchestration falls back to reconnect and revokes the token.

Implementations

impl<S> WireHandoffDelivery<S>

pub fn new( stream: S, service_name: impl Into<String>, correlation_id: u64, ) -> Self

Wrap a framed broker↔backend connection for one handoff.

correlation_id ties the offer to its ACK; reuse the request or connection id of the client Hello that triggered the handoff.

pub fn correlation_id(&self) -> u64

Return the correlation id stamped on the offer and required on the ACK.

pub fn stream(&self) -> &S

Borrow the underlying connection (e.g. to read its raw fd for the Unix SCM_RIGHTS send that precedes the offer frame).

pub fn into_stream(self) -> S

Unwrap the underlying connection (e.g. to keep using it after a completed handoff).

Trait Implementations

impl<S: Debug> Debug for WireHandoffDelivery<S>

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

Formats the value using the given formatter.

impl<S: Read + Write> HandoffDelivery for WireHandoffDelivery<S>

fn deliver( &mut self, handle: WindowsHandleValue, token: &HandoffToken, ) -> Result<(), HandoffDeliveryError>

Deliver the duplicated handle value and paired token to the backend.

fn await_backend_ack( &mut self, token: &HandoffToken, deadline: Instant, ) -> Result<Instant, HandoffDeliveryError>

Block until the backend acknowledges adopting the handed-off connection, or until deadline.