diff --git a/lib/bcoin/pool.js b/lib/bcoin/pool.js index 84c2b043..224d1449 100644 --- a/lib/bcoin/pool.js +++ b/lib/bcoin/pool.js @@ -815,10 +815,13 @@ Pool.prototype._createPeer = function _createPeer(backoff, priority) { }); peer.on('tx', function(tx) { - self._response(tx); - self._addTX(tx); + var requested, added; - self.emit('tx', tx, peer); + requested = self._response(tx); + added = self._addTX(tx); + + if (added || tx.block) + self.emit('tx', tx, peer); if (!self.options.fullNode && tx.block) self.emit('watched', tx, peer);