From 2a4f39a832fc1c59027d1003cf8b21c9e4f69c1e Mon Sep 17 00:00:00 2001 From: Andre Staltz Date: Tue, 23 Jan 2024 18:24:38 +0200 Subject: [PATCH] minor refactor --- lib/stream.js | 19 +++---------------- 1 file changed, 3 insertions(+), 16 deletions(-) diff --git a/lib/stream.js b/lib/stream.js index 2433dd1..f0e1b6e 100644 --- a/lib/stream.js +++ b/lib/stream.js @@ -22,52 +22,39 @@ const { isEmptyRange } = require('./range') class SyncStream extends Pipeable { #myId - /** @type {Algorithm} */ #algo - /** @type {CallableFunction} */ #debug - - /** Set of tangleId - * @type {Set} */ + /** @type {Set} Set of tangleId */ #requested - - /** tangleId => goal - * @type {PPPPPGoals} - */ + /** @type {PPPPPGoals} */ #goals - /** * tangleId => have-range by local peer * @type {Map} */ #localHave - /** * tangleId => want-range by local peer * @type {Map} */ #localWant - /** * tangleId => have-range by remote peer * @type {Map} */ #remoteHave - /** * tangleId => want-range by remote peer * @type {Map} */ #remoteWant - /** * tangleId => Set of msgIDs * @type {Map>} */ #receivableMsgs - /** * tangleId => Set of msgIDs * @type {Map>} @@ -457,7 +444,7 @@ class SyncStream extends Pipeable { const haveRange = this.#remoteHave.get(id) if (haveRange && isEmptyRange(haveRange)) { // prettier-ignore - this.#debug('%s Stream IN3: received remote want-range want-range %o and remember empty have-range %o for %s', this.#myId, wantRange, haveRange, id) + this.#debug('%s Stream IN3: received remote want-range %o and remembers empty have-range %o for %s', this.#myId, wantRange, haveRange, id) return this.#sendMsgsInRemoteWant(id, wantRange) } else { return this.#sendInitBloomRes(id, wantRange, bloom)