Function doWrite

packages/sdk/src/persist-queue.ts:46–59

()

  }

  function doWrite(): Promise<void> {
    if (disposed) return Promise.resolve();
    const content = session.serialize();
    writeChain = writeChain.then(async () => {
      if (disposed) return;
      try {
        await adapter.write(path, content);
      } catch (err) {
        const message = err instanceof Error ? err.message : String(err);
        opts.onError?.({ error: { message, cause: err } });
      }
    });
    return writeChain;
  }

  const unsubscribe = session.on("change", () => {
    scheduleWrite();