diff --git a/lib/services/address/index.js b/lib/services/address/index.js
index 48a5667b..65942da9 100644
--- a/lib/services/address/index.js
+++ b/lib/services/address/index.js
@@ -942,8 +942,8 @@ AddressService.prototype._streamAddressSummary = function(address, options, stre
 
       txIdTransformStream.on('end', function() {
         q.drain = (e, d)=> {
-          console.debug("END-DRAIN", d_count, td_count);
-          next(e, d);
+          console.debug("END-DRAIN", e, d, d_count, td_count);
+          next();
         };
         //q.resume();
       });