import { Runnable } from "https://deno.land/x/proc@0.20.7/src/runnable-iterable.ts";
Constructors
new
Runnable(iter: AsyncIterable<T>)Methods
concurrentMap<U>(mapFn: (item: T) => Promise<U>, concurrency?: number): Runnable<U>
Map the sequence from one type to another, concurrently.
Results are returned in order.
concurrentUnorderedMap<U>(mapFn: (item: T) => Promise<U>, concurrency?: number): Runnable<U>
Map the sequence from one type to another, concurrently.
Items are iterated out of order. This allows maximum concurrency at all times, but the output order cannot be assumed to be the same as the input order.
Filter the sequence to contain just the items that pass a test.
Perform an operation for each item in the sequence.
Reduce a sequence to a single value.
run<S>(options: ProcessOptions<S>, ...cmd: Cmd): Runnable<Uint8Array>
Run a process.
Transform the iterable from one type to another with an opportunity to catch and handle errors.
writeTo(writer: WritableIterable<T>)
Write all data to the writer.
Note that this call returns immediately, although it continues to run until the source iterable data is exhausted.
[Symbol.asyncIterator](): AsyncGenerator<T, void, unknown>