Struct PendingBatch 

pub struct PendingBatch {
    pub checkpoint: StreamCheckpoint,
    pub archive_deletes: Vec<ArchiveDelete>,
    pub archives: Vec<ArchiveWrite>,
    pub mutations: Vec<Mutation>,
    pub outputs: Vec<ChatOutput>,
    /* private fields */
}

A composed message waiting to be stored.

Store, in order, the checkpoint, the archive deletes, the archives, and the mutations; then ChatFacade::commit releases the frames. If storing fails, ChatFacade::reject fails them instead. The frames cannot reach the radio any other way.

Fields

checkpoint: StreamCheckpoint

archive_deletes: Vec<ArchiveDelete>

archives: Vec<ArchiveWrite>

mutations: Vec<Mutation>

outputs: Vec<ChatOutput>

Anything else the compose produced: deliveries, events, diagnostics.

Implementations

impl PendingBatch

pub fn id(&self) -> u64

Unique within a facade; never zero.

pub fn session_id(&self) -> u64

The session whose handles the mutations name.

pub fn transmission_count(&self) -> usize

How many frames the message goes out in. For an original message this matches the archive count, but an edit’s frames carry the editing option while its replacement archive is re-encoded without it, so the two can fragment differently.

Trait Implementations

impl Debug for PendingBatch

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

Formats the value using the given formatter.