Method waitBelow

src/extraction/store-writer.ts:157–162

Backpressure: resolves once fewer than `limit` bundles are un-acked.

(limit: number)

  /** Backpressure: resolves once fewer than `limit` bundles are un-acked. */
  waitBelow(limit: number): Promise<void> {
    if (this.firstError || this.exited || this.outstanding < limit) return Promise.resolve();
    return new Promise<void>((resolve) => {
      this.belowWaiters.push({ limit, resolve });
    });
  }

  /** Resolves when every bundle posted before this call has been applied. */
  drain(): Promise<void> {