method Source.prototype.withConcurrency
Source.prototype.withConcurrency(n: number): Source<T, E>

Sets the maximum number of concurrent operations for the stream.

Parameters

n: number

Return Type

Source<T, E>

Usage

import { Source } from ".";