Async

Promise-based utilities for async operations

9 utilities available

delay

Creates a promise that resolves after the specified number of milliseconds.

delay<T>(ms: number, value?: T): Promise<T>

sleep

Pauses execution for the specified number of milliseconds. Alias for delay without a return value.

sleep(ms: number): Promise<void>

retry

Retries an async function until it succeeds or max attempts are reached. Uses exponential backoff between retries.

retry<T>(fn: () => Promise<T>, options?: { retries?: number; delay?: number; backoff?: number; onRetry?: (error: Error, attempt: number) => void }): Promise<T>

timeout

Creates a promise that rejects if not resolved within the specified timeout.

timeout<T>(promise: Promise<T>, ms: number, message?: string): Promise<T>

parallel

Runs multiple async functions in parallel with a concurrency limit.

parallel<T>(tasks: (() => Promise<T>)[], limit?: number): Promise<T[]>

series

Runs async functions in series (one after another), passing results sequentially.

series<T>(tasks: (() => Promise<T>)[]): Promise<T[]>

waterfall

Runs async functions in series, passing the result of each function to the next. Similar to Array.reduce but for async operations.

waterfall<T>(tasks: ((value: any) => Promise<any>)[], initialValue?: T): Promise<any>

race

Creates a promise that resolves or rejects as soon as one of the promises resolves or rejects. Enhanced version of Promise.race with better error handling.

race<T>(promises: Promise<T>[]): Promise<T>

allSettled

Waits for all promises to settle (either resolve or reject) and returns their results. Enhanced version of Promise.allSettled with better TypeScript support.

allSettled<T>(promises: Promise<T>[]): Promise<Array<{ status: 'fulfilled'; value: T } | { status: 'rejected'; reason: any }>>