async library

Classes

CapturableStreamProvider<T>: A factory to expose CapturableStreamTarget's events as Streams.
CapturableStreamTarget<T>: An object that can be used as the target of the stream provided by CapturableStreamProvider.
StreamConsumerWrapper<S>: The StreamConsumer wrapper
StreamProvider<T>: A factory to expose StreamTarget's events as Streams.
StreamTarget<T>: An object that can be used as the target of the stream provided by StreamProvider.
StreamUtil: Stream utilities
StreamWrapper<T>: A Stream wrapper

cancelDeferred(dynamic key, {String? category}) → bool: Cancels the deferred execution of the given key. Returns true if the task is not yet executed.
configureDefers({FutureOr executor(dynamic key, Function task, String? category, {void onActionDone()?, void onError(dynamic ex, StackTrace st)?})?, Duration? executable(int runningCount)?, Duration? maxBusy}) → void: Configures how to execute a deferred task.
defer<T>(T key, FutureOr task(T key), {Duration min = const Duration(seconds: 1), Duration? max, String? category}) → void: Defers the execution of a task. If the key is the same, the task in the second invocation will override the previous. In other words, the previous task is canceled.
flushDefers({void onActionStart(dynamic key, String? category)?, void onActionDone(dynamic key, String? category)?, void onError(dynamic ex, StackTrace st)?, Duration? repeatLater}) → FutureOr: Force all deferred task (queued by defer) to execute. If the task given in defer returns an instance of Future, this method will wait until it completes.