@epikodelabs/streamix

---

@epikodelabs/streamix / src/public-api / raceNext

Function: raceNext()

raceNext<T>(iterator, signal): Promise<IteratorResult<T, any>>

Defined in: projects/libraries/streamix/src/lib/utils/coordinator.ts:630

Races an iterator's next() call against an AbortSignal. If the signal is aborted, the promise resolves with a done: true result.

Type Parameters

T

T

Parameters

iterator

AsyncIterator<T, any, any> | Iterator<T, any, any>

signal

AbortSignal

Returns

Promise<IteratorResult<T, any>>