Skip to content

watchChunks

function watchChunks<T>(watch, chunks): AsyncGenerator<T>;

Defined in: core/src/watchdog.ts:171

Wrap a stream so every chunk re-arms watch, and a failure is re-classified through it. Disposes on any exit: completion, throw, or the consumer breaking out of the loop.

Type Parameter
T
Parameter Type
watch StreamWatch
chunks AsyncIterable<T>

AsyncGenerator<T>