@epikodelabs/streamix

---

@epikodelabs/streamix / asyncPull

Function: asyncPull()

asyncPull<T>(state, _iterator, onDone?): Promise<IteratorResult<T, any>>

Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:117

Asynchronous pull handler - implements next() logic

Type Parameters

T

T

Parameters

state

AsyncIteratorState<T>

_iterator

any

onDone?

() => void

Returns

Promise<IteratorResult<T, any>>