Method failAll

src/extraction/store-writer.ts:129–137

(err: Error)

  }

  private failAll(err: Error): void {
    if (!this.firstError) this.firstError = err;
    for (const [, waiter] of this.drainWaiters) waiter.reject(this.firstError);
    this.drainWaiters.clear();
    this.outstanding = 0;
    const waiters = this.belowWaiters;
    this.belowWaiters = [];
    for (const w of waiters) w.resolve(); // send() will surface firstError
  }

  private settleOne(): void {
    if (this.outstanding > 0) this.outstanding--;