Method drain

src/extraction/store-writer.ts:165–174

Resolves when every bundle posted before this call has been applied.

()

  /** Resolves when every bundle posted before this call has been applied. */
  drain(): Promise<void> {
    if (this.firstError) return Promise.reject(this.firstError);
    if (this.exited) return Promise.reject(new Error('store worker already exited'));
    const id = this.nextDrainId++;
    const p = new Promise<void>((resolve, reject) => {
      this.drainWaiters.set(id, { resolve, reject });
    });
    this.worker.postMessage({ type: 'drain', id });
    return p;
  }

  /** Close the worker's DB connection and join the thread. */
  async close(): Promise<void> {