LevitTasksMixin mixin

Adds named task execution, conflict policies, retries, and cancellation.

Superclass constraints

Properties

disposed Future<void>
Completes when cleanup reaches its terminal state.
no setterinherited
hashCode int
The hash code for this object.
no setterinherited
initialized bool
Whether onInit has been executed.
no setterinherited
isClosed bool
Whether the controller has been disposed and closed.
no setterinherited
isClosing bool
Whether owner cleanup has started.
no setterinherited
isDisposed bool
Whether cleanup has completed.
no setterinherited
isInitialized bool
Whether the initialization phase is complete.
no setterinherited
maxConcurrentTasks int
Maximum number of concurrent task executions.
no setter
onTaskError → void Function(Object error, StackTrace stackTrace)?
Optional default error handler for terminal failures.
no setter
onTaskEvent → void Function(LevitTaskEvent event)?
Optional controller-local task event observer.
no setter
ownedResources Iterable<Object>
Resources currently tracked by this owner.
no setterinherited
ownerPath String
The full owner path within the monitoring system (scopeId:registrationKey).
no setterinherited
registrationKey String?
The registration key used to identify this instance in Levit.
no setterinherited
resourceOwnerPath String
A diagnostic owner path applied to otherwise unnamed reactive resources.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited
scope LevitScope?
The LevitScope that currently owns this controller.
no setterinherited
taskCacheProvider LevitTaskCacheProvider?
Optional persistent cache provider.
no setter
tasksEngine LevitTaskEngine
The controller-owned task engine.
no setter

Methods

autoDispose<T>(T object) → T
Registers object for automatic cleanup when the controller closes.
inherited
didAttachToScope(LevitScope scope, {String? key}) → void
Attaches this controller to an owning scope with an optional registration key.
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
onClose() FutureOr<void>
Called when the controller is removed from memory.
override
onInit() → void
Called immediately after the controller is initialized.
override
own<T>(T resource) → T
Registers resource for deterministic cleanup and returns it.
inherited
refreshOwnedReactivePaths() → void
Reconciles already-owned reactive diagnostics after scope attachment.
inherited
runGuardedAsync<T>(FutureOr<T> action(), {bool cancelOnClose = true, void onError(Object error, StackTrace stackTrace)?}) Future<T?>
Executes action and suppresses its result if this controller closes first.
inherited
runIsolateTask<I, T>(LevitIsolateTask<I, T> task, I input, {String? id, TaskPriority priority = TaskPriority.normal, TaskConflictPolicy conflictPolicy = TaskConflictPolicy.reject, int retries = 0, Duration? retryDelay, bool useExponentialBackoff = true, void onError(Object error, StackTrace stackTrace)?, TaskCachePolicy<T>? cachePolicy, LevitTaskMetadata? metadata, String? debugName}) Future<T?>
Runs a top-level/static task in a new isolate.
runTask<T>(FutureOr<T> task(LevitTaskContext context), {String? id, TaskPriority priority = TaskPriority.normal, TaskConflictPolicy conflictPolicy = TaskConflictPolicy.reject, int retries = 0, Duration? retryDelay, bool useExponentialBackoff = true, void onError(Object error, StackTrace stackTrace)?, TaskCachePolicy<T>? cachePolicy, LevitTaskMetadata? metadata, String? debugName}) Future<T?>
Runs a task using this controller's owned engine.
toString() String
A string representation of this object.
inherited

Operators

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