AbstractAsyncIter | /tests/deps/asynciter.ts | proc@0.20.34

Module

x/proc/tests/deps/asynciter.ts>AbstractAsyncIter

A better way to work with processes in Deno.

j50n/deno-proc

assertNotStrictEquals

concurrentUnorderedMap

map

dim

red

FormatInputPathObject

SEP

LimitedBytesTransformStream

LimitedTransformStream

TextDelimiterStream

TextLineStream

DelimiterStreamOptions

ReadableStreamFromReaderOptions

WritableStreamFromWriterOptions

DelimiterDisposition

copy

earlyZipReadableStreams

iterateReader

iterateReaderSync

mergeReadableStreams

readableStreamFromIterable

readableStreamFromReader

readAll

readAllSync

readerFromIterable

readerFromStreamReader

toTransformStream

writableStreamFromWriter

writeAll

writeAllSync

writerFromStreamWriter

zipReadableStreams

class AbstractAsyncIter

implements IAsyncIter<T>

Abstract

import { AbstractAsyncIter } from "https://deno.land/x/proc@0.20.34/tests/deps/asynciter.ts";

Type Parameters

Properties

protected

abstract

readonly

iterator: AsyncIterable<T>

Methods

collect(): Promise<T[]>

Collect the items in this iterator to an array.

concurrentMap(mapFn: (item: T) => Promise, concurrency?: number): AsyncIter

Map the sequence from one type to another, concurrently.

Results are returned in order.

concurrentUnorderedMap(mapFn: (item: T) => Promise, concurrency?: number): AsyncIter

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(filterFn: (item: T) => boolean | Promise<boolean>): AsyncIter<T>

Filter the sequence to contain just the items that pass a test.

first(): Promise<T | null>

Return the first item of the sequence.

flatten(): AsyncIter

Flatten the iterable.

forEach(forEachFn: (item: T) => void | Promise<void>): Promise<void>

Perform an operation for each item in the sequence.

map(mapFn: (item: T) => U | Promise): AsyncIter

Map the sequence from one type to another.

reduce(zero: U, reduceFn: (acc: U, item: T) => U | Promise): Promise

Reduce a sequence to a single value.

[Symbol.asyncIterator](): AsyncGenerator<T, void, unknown>