Graphorin API reference v0.1.0

---

Graphorin API reference / @graphorin/core / / mapStream

Function: mapStream()

function mapStream<T, U>(
   source, 
   fn, 
signal?): AsyncIterable<U>;

Defined in: packages/core/src/utils/streams.ts:39

Map every value of an async iterable. The mapper may be async. Cancellation via signal is honored.

Type Parameters

Type Parameter
T
U

Parameters

Parameter	Type
source	AsyncIterable<T>
fn	(value, index) => U | Promise<U>
signal?	AbortSignal

Returns

AsyncIterable<U>

Stable