From 69a829a6ebf26ff9ebedc081ea7a5296a3fdead6 Mon Sep 17 00:00:00 2001 From: sairajzero Date: Sat, 28 Jan 2023 01:46:39 +0530 Subject: [PATCH] Update index.js --- lib/services/address/index.js | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/lib/services/address/index.js b/lib/services/address/index.js index ab1907de..636020c4 100644 --- a/lib/services/address/index.js +++ b/lib/services/address/index.js @@ -737,7 +737,7 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre }, 4); - q.empty(() => console.debug("Q-EMPTY")); + q.empty = () => console.debug("Q-EMPTY"); q.pause(); //pause and wait until queue is set @@ -806,9 +806,11 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre var txidStream = self._getTxidStream(address, options); txidStream.pipe(txIdTransformStream); - await q.drain(); - console.debug("Q-DRAIN"); - next(); + q.drain = function(){ + console.debug("Q-DRAIN"); + next(); + }; + } ], callback);