Struct DeliveredMessage 

pub struct DeliveredMessage { /* private fields */ }

A message the server delivered on this subscription.

Implementations

impl DeliveredMessage

pub const fn delivery_seq(&self) -> u64

The per-subscription monotonic delivery sequence (starts at 1). The anchor the future ack/resume protocol will acknowledge against.

pub const fn schema_id(&self) -> SchemaId

The schema id the server selected for this subscription’s stream.

pub fn payload(&self) -> &[u8]

The delivered payload bytes.

pub fn into_payload(self) -> Vec<u8>

Consumes the message, returning the owned payload bytes.

pub const fn message(&self) -> Option<DeliveredId>

The server’s id for this message and the boot it was drawn in, when the server sent it (protocol 1.2, Fable 4c). None from an older server, and for a durable message replayed from the store.

pub fn reply_parent(&self) -> Option<MessageId>

The causal parent a reply to this message names, <boot>:<id>, or None when the message carried no id: never an invented one.

Trait Implementations

impl Clone for DeliveredMessage

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DeliveredMessage

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

Formats the value using the given formatter.

impl Eq for DeliveredMessage

impl From<WebSocketDeliveredMessage> for DeliveredMessage

One delivered message, whichever transport carried it: the WebSocket sibling’s fields are the TCP message’s (AGT-006 R2).

fn from(message: WebSocketDeliveredMessage) -> Self

Converts to this type from the input type.

impl PartialEq for DeliveredMessage

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for DeliveredMessage