diff --git a/lib/stream.js b/lib/stream.js index 58510a1..61dd523 100644 --- a/lib/stream.js +++ b/lib/stream.js @@ -369,6 +369,7 @@ class SyncStream extends Pipeable { #consumeMissingMsgs(id, msgsForMe) { // prettier-ignore this.#debug('%s Stream IN9: got %s msgs in %s', this.#myId, msgsForMe.length, id) + const localWantRange = this.#localWant.get(id) this.#requested.delete(id) this.#localHave.delete(id) @@ -381,7 +382,6 @@ class SyncStream extends Pipeable { if (msgsForMe.length === 0) return const goal = this.#goals.get(id) if (!goal) throw new Error(`No goal found for "${id}"`) - const localWantRange = this.#localWant.get(id) if (!localWantRange) throw new Error('local want-range not set') try { this.#algo.commit(id, msgsForMe, goal, localWantRange)