async.ts - 🕹 Loscore documentation

Functions

f

collectUint8Array(iterable: AsyncIterable<Uint8Array>): Promise<Uint8Array>

f

defer<T, F extends (...args: never[]) => Promise<T>>(callback: F): ((...args: Parameters<F>) => Promise<T>)

f

iterable: AsyncIterable<T>,

check: (value: T) => unknown

): AsyncIterable<T>

f

iterable: AsyncIterable<T[]>,

): AsyncIterable<T[]>

f

flatten<T>(iterable: GeneralIterable<GeneralIterable<T>>): AsyncIterable<T>

f

iterable: AsyncIterable<T>,

accumulator: S,

f

isAsyncIterable(data: unknown): data is AsyncIterable<unknown>

f

iterable: AsyncIterable<T>,

convert: (value: T) => S

): AsyncIterable<S>

f

mapStream<T, S>(

stream: ReadableStream<T>,

callback: (value: T) => S

): ReadableStream<S>

f

iterable: AsyncIterable<T>,

accumulator: T,

): Promise<T | undefined>

f

sleep(ms: number): Promise<void>

f

iterable: AsyncIterable<T>,

): AsyncIterable<T>

f

sum(iterable: AsyncIterable<number>): Promise<number>

f

toStream<T>(iterable: AsyncIterable<T>): ReadableStream<T>

Type Aliases

T

GeneralIterable<T> = AsyncIterable<T> | Iterable<T>

Usage

import * as mod from "async.ts";