@epikodelabs/streamix

---

@epikodelabs/streamix / pushValue

Function: pushValue()

pushValue<T>(state, _iterator, value, onPush?): void | Promise<void>

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

Push a value with backpressure support

Type Parameters

T

T

Parameters

state

AsyncIteratorState<T>

_iterator

any

value

T

onPush?

() => void

Returns

void | Promise<void>