ZenMutationQueue class
Manages the offline mutation queue.
Stores failed mutations and replays them when the network returns.
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- pendingCount → int
-
Get the number of pending mutations in the queue
no setter
-
pendingJobs
→ List<
ZenMutationJob> -
Get a list of pending mutation jobs (for debugging/devtools)
no setter
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
add(
ZenMutationJob job) → void - Add a job to the queue
-
init(
ZenStorage? storage) → Future< void> - Initialize the queue and restore from storage if available
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
process(
) → Future< void> - Process the queue (replay mutations)
-
registerHandlers(
Map< String, ZenMutationHandler> handlers) → void - Register mutation handlers
-
remove(
String id) → void - Remove a job from the queue
-
setNetworkStream(
Stream< bool> stream) → void - Set the network stream to listen for connectivity changes
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited
Static Properties
- instance → ZenMutationQueue
-
final