Method subscribe

packages/y-graph-storage/src/YGraph.ts:273–283

(observer: Observer<YGraphChange>)

  }

  public subscribe(observer: Observer<YGraphChange>) {
    const predicate = this.#predicate;
    return this.#graph.subscribe({
      next(value) {
        const step = predicate(value);
        if (step != undefined) {
          observer.next?.(value);
        }
      },
    });
  }

  public traverse(): Iterable<PathFromTraversal<TTraversal>> {
    return this.#traversal.traverse();