Class BufferContentProvider

packages/markmap-cli/src/util/dev-server.ts:35–101

}

class BufferContentProvider implements IContentProvider {
  private deferredSet = new Set<IDeferred<void>>();

  state: IFileState = {
    content: {
      ts: 0,
      value: '',
    },
    line: {
      ts: 0,
      value: 0,
    },
  };

  protected disposeList: Array<() => void> = [];

  constructor(readonly key: string) {}

  async getUpdate(query: Record<string, number>, timeout = 10000) {
    const deferred = defer<void>();
    this.deferredSet.add(deferred);
    setTimeout(() => {
      this.feed(null, deferred);
    }, timeout);
    if (Object.keys(query).some((key) => query[key] < this.state[key].ts)) {
      this.feed(null, deferred);
    }
    await deferred.promise;
  }

  protected feed(data: Partial<IFileState> | null, deferred?: IDeferred<void>) {
    if (data) {
      Object.assign(this.state, data);
    }
    if (deferred) {
      deferred.resolve();
      this.deferredSet.delete(deferred);
    } else {
      for (const d of this.deferredSet) {
        d.resolve();
      }
      this.deferredSet.clear();
    }
  }

  setCursor(line: number) {
    this.feed({
      line: {
        ts: Date.now(),
        value: line,
      },
    });
  }

  setContent(content: string) {
    this.feed({
      content: {
        ts: Date.now(),