@@ -43,28 +43,6 @@ class Graph extends EventTarget {
4343 this . #graph. set ( safeNode [ '@id' ] , safeNode ) ;
4444 }
4545
46- observe ( ) : AsyncIterator < GraphChangeEvent , any , any > {
47- const observerControllerSet = this . #observerControllerSet;
48- let thisController : ReadableStreamDefaultController < GraphChangeEvent > ;
49-
50- const stream = new ReadableStream < GraphChangeEvent > ( {
51- cancel ( ) {
52- // Iterator.cancel() will call cancel().
53- observerControllerSet . delete ( thisController ) ;
54- } ,
55- start ( controller ) {
56- thisController = controller ;
57- observerControllerSet . add ( controller ) ;
58- }
59- } ) ;
60-
61- return stream . values ( ) ;
62- }
63-
64- snapshot ( ) {
65- return new Map ( this . #graph) ;
66- }
67-
6846 // eslint-disable-next-line complexity
6947 #setTriplet(
7048 subjectId : Identifier ,
@@ -159,6 +137,28 @@ class Graph extends EventTarget {
159137 return Object . freeze ( affectedIds ) ;
160138 }
161139
140+ observe ( ) : AsyncIterator < GraphChangeEvent , any , any > {
141+ const observerControllerSet = this . #observerControllerSet;
142+ let thisController : ReadableStreamDefaultController < GraphChangeEvent > ;
143+
144+ const stream = new ReadableStream < GraphChangeEvent > ( {
145+ cancel ( ) {
146+ // Iterator.cancel() will call cancel().
147+ observerControllerSet . delete ( thisController ) ;
148+ } ,
149+ start ( controller ) {
150+ thisController = controller ;
151+ observerControllerSet . add ( controller ) ;
152+ }
153+ } ) ;
154+
155+ return stream . values ( ) ;
156+ }
157+
158+ snapshot ( ) {
159+ return new Map ( this . #graph) ;
160+ }
161+
162162 /**
163163 * Upserts a list of nodes in a transaction. Will trigger observers once upsert has completed.
164164 *
0 commit comments