Skip to main content

ConcurrentMap<Input, Output, ErrorOutput>

Defined in: src/ConcurrentMap.ts:21

The operator object behind concurrentMap. Prefer the concurrentMap function or the chain method.

Type Parameters​

Input​

Input

Output​

Output

ErrorOutput​

ErrorOutput = never

Implements​

Constructors​

Constructor​

new ConcurrentMap<Input, Output, ErrorOutput>(options, mapper, errorMapper?): ConcurrentMap<Input, Output, ErrorOutput>

Defined in: src/ConcurrentMap.ts:150

Parameters​

options​

ConcurrentMapOptions

mapper​

(input) => Output | Promise<Output>

errorMapper?​

(input, error) => ErrorOutput | Promise<ErrorOutput>

Returns​

ConcurrentMap<Input, Output, ErrorOutput>

Methods​

process()​

process(input): AsyncIterable<Output | ErrorOutput>

Defined in: src/ConcurrentMap.ts:163

Parameters​

input​

Iter<Input>

Returns​

AsyncIterable<Output | ErrorOutput>

Implementation of​

OperatorObject.process