@epikodelabs/streamix / networking/src/public-api / flow
Function: flow()
flow<
T>(factory):Stream<T>
Defined in: projects/libraries/streamix/networking/src/lib/stream.ts:26
Creates a fresh cancellable async iterator for every consumer. Returning from or throwing into the iterator aborts its factory signal.
Type Parameters
T
T
Parameters
factory
(signal) => AsyncIterable<T>
Returns
Stream<T>