future_utils library

Functions

asyncMap<T, TRet>(List<T> items, Future<TRet> selector(T), {int maxConcurrency = 4}) → Future<Map<T, TRet>>

Maps a list of values to a new Map using an asynchronous selector function with concurrency control.

asyncReduce<T, TAcc>(List<T> items, Future<TAcc> selector(TAcc acc, T item), TAcc seed) → Future<TAcc>

Reduces a list using an asynchronous selector function.

fromCancellableFuture<T>(Future<T> block(CancellationToken token)) → Stream<T>

Converts a Future factory (with cancellation token) to a Stream.

retryFuture<T>(Future<T> func(), {int retries = 3}) → Future<T>

Retries a Future-returning function a specified number of times.