MessagingSubscriptions class

Inheritance

Constructors

MessagingSubscriptions({required AuthenticatedSessionUser user, String? subTopic, ChaCha20Key? chaChaKey})

Properties

chaChaKey → ChaCha20Key?
final
fps ↔ int
getter/setter pairinherited
hashCode → int
The hash code for this object.
no setterinherited
hasListeners → bool
Whether any listeners are currently registered.
no setterinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
subscriptions → Map<String, TopicSubscription>
final
subTopic → String?
final
user → AuthenticatedSessionUser
final
waitingEvents → SplayTreeMap<int, Broadcast>
finalinherited
wasSeen ↔ Map<String, bool>
A transactional memory map tracking processed event UUIDs to guarantee local idempotency.
getter/setter pairinherited

Methods

addListener(VoidCallback listener) → void
Register a closure to be called when the object changes.
inherited
dispatchWaitingEvents() → void
inherited
dispose() → void
Discards any resources used by the object.
inherited
executeQueue() → void
Optional: Execute queued notifications manually if needed
inherited
fetchEngram() → Future<Engram?>
Retrieves the latest structurally verified historical anchor block available from the system cluster.
inherited
getCurrentSequenceId() → int
Returns the highest sequentially verified sequence identifier processed by this instance.
inherited
getLocalizedTopic() → String
Returns the fully qualified namespace string for the message channel.
inherited
getTopic() → String
Returns the raw base identifier of the communication topic.
initializeFromEngram(Engram engram) → Future<void>
Instantiates or hydrates the internal runtime properties using a historical compressed snapshot.
inherited
initializeFromEngramAndSetSequenceId(Engram engram) → Future<void>
Instantiates or hydrates the internal runtime properties using a historical compressed snapshot.
inherited
isTopicSharedAcrossApps() → bool
Returns whether this topic is exposed globally to external ecosystem applications.
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
notifyListeners() → void
Override notifyListeners to throttle the notifications
inherited
onReceive(Broadcast localityEvent) → void
Processes broadcasts dispatched to the channel.
preprocessEvent(Broadcast localityEvent) → void
Inspects, filters, and commits incoming chronological records to the instance runtime.
inherited
removeListener(VoidCallback listener) → void
Remove a previously registered closure from the list of closures that are notified when the object changes.
inherited
send(String event, Map<String, dynamic> payload) → Broadcast
Transmits a new mutation request into the decentralized channel flow.
inherited
sendEngram(String serializedState) → Future<bool>
Dispatches a compressed snapshot string representing the current localized state boundary to the network authority.
inherited
subscribe(TopicSubscription subscription) → void
toString() → String
A string representation of this object.
inherited
unsubscribe(String topic) → void
useEngrams() → bool
Returns whether this state structure integrates with optimized history-compaction layers.
inherited

Operators

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