@epikodelabs/streamix

---

@epikodelabs/streamix / eachValueFrom

Function: eachValueFrom()

eachValueFrom<T>(stream): AsyncGenerator<T>

Defined in: projects/libraries/streamix/src/lib/converters/eachValueFrom.ts:26

Converts a Stream into an async generator, yielding each emitted value. Distinguishes between undefined values and stream completion.

This function creates a bridge between the push-based nature of a stream and the pull-based nature of an async generator. It relies on the stream's async-iterable interface (backed by the same multicast machinery used for subscriptions), so for await...of eachValueFrom(stream) is equivalent to for await...of stream.

The generator handles all stream events:

• Each yielded value corresponds to a next event, including undefined values.
• The generator terminates when the stream completes.
• It throws an error if the stream emits an error event.

It correctly handles situations where the stream completes or errors out before any values are yielded, and ensures the subscription is always cleaned up.

Type Parameters

T

T = any

The type of the values emitted by the stream.

Parameters

stream

Stream<T>

The source stream to convert.

Returns

AsyncGenerator<T>

An async generator that yields the values from the stream.