Function withFlushAsync

lib/internal/streams/iter/pull.js:643–646

* Append a null flush signal after the source is exhausted. * @yields {Uint8Array[]}

(source)

 * @yields {Uint8Array[]}
 */
async function* withFlushAsync(source) {
  yield* source;
  yield null;
}

async function* applyStatefulAsyncTransform(source, transform, options) {
  const output = transform(withFlushAsync(source), options);