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);