async_tools library

Classes

AsyncData<T>
AsyncError<T>
AsyncLoading<T>
AsyncTagLock<T>
AsyncValue<T>: An utility for safely manipulating asynchronous data.
DelayedWaitSet<T>: Execute a set of async closures (functions returninga Future) in batches.
Mutex: Mutual exclusion.
ReadWriteMutex: Mutual exclusion that supports read and write locks.
SingleStatelessProcessor: Process a single stateless update at a time ensuring each request gets processed asynchronously, and continuously while update is requested.
SingleStateProcessor<State>: Process a single state update at a time ensuring the most recent state gets processed asynchronously, possibly skipping states that happen while a previous state is still being processed.
SingleStateProcessorMap<Key, State>: A map-like data structure that manages continuous single-state updates for a set of keys.
WaitSet<T>: Execute a set of async closures (functions returning a Future) immediately but wait until they all finish. Closures are immediately executed upon calling 'add'.

serialFuture<T>(Object tag, Future<T> closure(), {void onDone(T)?, void onError(Object e, StackTrace? st)?}) → void: Process a single future at a time per tag queued serially
serialFuturePause(Object tag) → Future<void>
serialFutureResume(Object tag) → void
singleFuture<T>(Object tag, Future<T> closure(), {void onBusy()?, void onDone(T)?, void onError(Object e, StackTrace? st)?}) → void: Process a single future at a time per tag
singleFuturePause(Object tag) → Future<void>
singleFutureResume(Object tag) → void