Enum RemoteParticipantInbound 

pub enum RemoteParticipantInbound {
    Applied {
        value: ServerValue,
        provenance: ParticipantResponseProvenance,
    },
    Refused {
        value: ServerValue,
        reason: ClientInboundRefusalReason,
        provenance: ParticipantResponseProvenance,
    },
    Push {
        value: ServerPush,
        provenance: ParticipantResponseProvenance,
    },
}

Typed result of one decoded participant frame on the real receive path.

Variants

Applied

The protocol crate correlated and applied a semantic response.

Fields

value: ServerValue

Exact applied server value.

provenance: ParticipantResponseProvenance

Connection/attempt that delivered it.

Refused

The protocol crate retained the response and aggregate unchanged.

Fields

value: ServerValue

Exact refused server value.

reason: ClientInboundRefusalReason

Closed crate refusal reason, including conservative ambiguity.

provenance: ParticipantResponseProvenance

Connection/attempt that delivered it.

Push

Server push decoded in the client direction; no correlation rule applies.

Fields

value: ServerPush

Exact pushed value.

provenance: ParticipantResponseProvenance

Connection/attempt that delivered it.

Implementations

impl RemoteParticipantInbound

pub const fn committed_delivery_seq(&self) -> Option<DeliverySeq>

The record sequence the server assigned an admitted record, when this inbound is an APPLIED ServerValue::RecordCommitted.

This is the answer to a RecordAdmission, read off the exact wire value the protocol crate applied. It saves every caller destructuring the wire enum to reach the one number a record admission is asked for, without removing that value: Applied still carries the whole ServerValue, so this is purely additive.

None for everything else, and that includes a RecordCommitted the crate REFUSED. A refused commit carries a sequence on the wire while leaving the aggregate and its correlation untouched – returning it here would report a commitment the crate deliberately declined to make. It is also None for a Push, which is a delivery rather than a correlated response.

Trait Implementations

impl Debug for RemoteParticipantInbound

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

Formats the value using the given formatter.