Function applyValidatedStatefulAsyncTransform

lib/internal/streams/iter/pull.js:680–691

* Fast path for validated stateful transforms (e.g. compression). * Skips withFlushAsync (transform handles done internally) and * skips isUint8ArrayBatch validation (transform guarantees valid output). * @yields {Uint8Array[]}

(source, transform, options)

 * @yields {Uint8Array[]}
 */
async function* applyValidatedStatefulAsyncTransform(source, transform, options) {
  const output = transform(source, options);
  for await (const batch of output) {
    if (batch.length > 0) {
      yield batch;
    }
  }
  // Check abort after the transform completes - without the
  // withFlushAsync wrapper there is no extra yield to give
  // the outer pipeline a chance to see the abort.
  options.signal?.throwIfAborted();
}

function getOnAbort(reject, signal) {
  return () => reject(signal.reason);