StoredOutbox<S extends OutboxStore> class

Storage-independent durable outbox protocol.

The name avoids colliding with RelayCell's established Outbox<T> facade.

Implemented types
Implementers

Constructors

StoredOutbox(S store)

Properties

ackedThrough int
The highest loaded or observed peer acknowledgement.
no setter
hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited
store → S
final

Methods

ackThrough(Epoch epoch) → void
The peer proved receipt through epoch; retained frames <= epoch MAY be pruned.
override
append(Epoch epoch, IpcMessage msg) → void
Persist msg at epoch before it is handed to the transport.
override
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
replayFrom(Epoch cursor) List<OutboxFrame>
Retained frames with epoch > cursor, in ascending epoch order.
override
retainedEpochs() List<Epoch>
Epochs still retained (not yet acked), ascending — for diagnostics/tests.
override
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited