PubSubSupervisor class

Constructors

PubSubSupervisor()

Properties

hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toString() String
A string representation of this object.
inherited

Operators

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

Static Properties

cache Cache?
An optional static instance of Cache, used for caching purposes.
getter/setter pair
emittedEventForUUID Map<String, bool>
A static map that tracks whether an event has been emitted for a specific UUID. This is used to prevent duplicate event emissions for the same UUID.
getter/setter pair
eventSink EventSink
getter/setter pair
standardEventSink EventSink
getter/setter pair
supervisedTopicByTopic Map<String, SupervisedTopic>
A static map that associates topics with their respective PubSub instances. This facilitates the publishing and subscribing of events related to specific topics.
getter/setter pair
supervisor Supervisor
A static instance of Supervisor, responsible for supervising processes and managing their lifecycle within the application.
getter/setter pair

Static Methods

fetchSince(PubSub pubSub, int milissinceepoch) → void
processEvent(PubSub pubSub, Map<String, dynamic> payload, ChaCha20Key? key) → void
registerPubSub(PubSub pubSub, {ChaCha20Key? key, int? syncSince}) → void
sendMessage(PubSub pubSub, String event, Map<String, dynamic> payload) WaitingMessage