TWQueue class

Queue to execute Futures in order. It awaits each future before executing the next one.

Constructors

TWQueue({Duration? delay, int parallel = 1, Duration? timeout, bool lifo = false})

activeItemTags ↔ Set<String>: active items tags
getter/setter pair
delay → Duration?: A delay to await between each future.
final
hashCode → int: The hash code for this object.
no setterinherited
isPause ↔ bool: pause of the queue
getter/setter pair
lifo → bool: Shoud we process this queue LIFO (last in first out)
final
onComplete → Future: Resolve when all items are complete
no setter
parallel ↔ int: The number of items to process at one time
getter/setter pair
remainingItems → Stream<int>: no setter
runtimeType → Type: A representation of the runtime type of the object.
no setterinherited
timeout → Duration?: A timeout before processing the next item in the queue
final

add<T>(Future<T> closure(), {String? tag, TWPriority priority = TWPriority.middle}) → Future<T>: Adds the future-returning closure to the queue.
cancel() → void: Cancels the queue. Also cancels any unprocessed items throwing a QueueCancelledException
dispose() → void: Dispose of the queue
noSuchMethod(Invocation invocation) → dynamic: Invoked when a nonexistent method or property is accessed.
inherited
pause() → void: pause of the queue It will be pause the queue if it has not yet been executed.
remove(String tag, {TWPriority priority = TWPriority.middle}) → void: Removes the future-returning closure from the queue. It will be removed from the queue if it has not yet been executed.
resume() → void: resume of the queue
toString() → String: A string representation of this object.
inherited