Method batch

src/node/utils/Stream.ts:57–73

* Read values a chunk at a time from the underlying iterable. Once a full batch is read (or there * aren't enough values to make a full batch), all of the batch's values are yielded before the * next batch is read. * * This is useful for triggering groups of asynchronous tasks via Promis

(size: number)

   * @returns {Stream} A new Stream that gets its values from this Stream.
   */
  batch(size: number) {
    return new Stream((function* () {
      const b = [];
      try {
        // @ts-ignore
        for (const v of this) {
          Promise.resolve(v).catch(() => {}); // Suppress unhandled rejection errors.
          b.push(v);
          if (b.length < size) continue;
          while (b.length) yield b.shift();
        }
        while (b.length) yield b.shift();
      } finally {
        for (const v of b) Promise.resolve(v).then(() => {}); // Un-suppress unhandled rejections.
      }
    }).call(this));
  }

  /**
   * Pre-fetch a certain number of values from the underlying iterable before yielding the first