diff --git a/lib/bcoin/pool.js b/lib/bcoin/pool.js index 152b7ead..eed4b085 100644 --- a/lib/bcoin/pool.js +++ b/lib/bcoin/pool.js @@ -285,7 +285,9 @@ Pool.prototype._addPeer = function _addPeer(backoff) { peer.updateWatch(); self.tx.list.forEach(function(entry) { - peer.broadcast(entry.tx)[0].once('request', function() { + var result = peer.broadcast(entry.tx); + if (!result) return; + result[0].once('request', function() { entry.e.emit('ack'); }); }); @@ -703,7 +705,9 @@ Pool.prototype.sendTX = function sendTX(tx) { this.tx.list.push(entry); this.peers.block.forEach(function(peer) { - peer.broadcast(tx)[0].once('request', function() { + var result = peer.broadcast(tx); + if (!result) return; + result[0].once('request', function() { e.emit('ack'); }); });