diff --git a/lib/stream.js b/lib/stream.js index af4fbee..2ec7cb4 100644 --- a/lib/stream.js +++ b/lib/stream.js @@ -107,7 +107,7 @@ class SyncStream extends Pipeable { this.resume() this.#goals.watch((/** @type {any} */ goal) => { - if (!this.#requested.has(goal.id)) { + if (!this.#requested.has(goal.id) && goal.type !== 'none') { this.#requested.add(goal.id) this.resume() }