fromAsyncIter()

Pulls async values from an AsyncIterable or () => AsyncIterable (factory for retry/repeat) (Tier 2).

Signature

function fromAsyncIter<T>(
	iterableOrFactory: AsyncIterable<T> | (() => AsyncIterable<T>),
): ProducerStore<T>

Parameters

Parameter	Type	Description
iterableOrFactory	`AsyncIterable<T>	(() => AsyncIterable<T>)`

Returns

ProducerStore<T> — aborts iteration when last sink disconnects.

Options / Behavior Details

• Factory: Prefer () => gen() for resubscribable sources.