support preonchange for watchers (#151)

* support preonchange for watchers * just auto flush instead
holepunchto · May 3, 2024 · fb8d7a5 · fb8d7a5
1 parent 549a449
commit fb8d7a5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/index.js b/index.js
@@ -1212,6 +1212,7 @@ class Watcher extends ReadyResource {
     this._eager = !!opts.eager
     this._updateOnce = !!opts.updateOnce
     this._onchange = opts.onchange || null
+    this._flush = opts.flush !== false && this.core.isAutobase
 
     this.on('newListener', autoFlowOnUpdate)
 
@@ -1295,6 +1296,7 @@ class Watcher extends ReadyResource {
           await this.bee.update({ wait: true })
         }
 
+        if (this._flush) await this.core.base.flush()
         if (this.closing) return { value: undefined, done: true }
 
         await this._closePrevious()