diff --git a/lib/bcoin/pool.js b/lib/bcoin/pool.js index 7a1894d7..152b7ead 100644 --- a/lib/bcoin/pool.js +++ b/lib/bcoin/pool.js @@ -118,8 +118,8 @@ Pool.prototype._addLoader = function _addLoader() { this.peers.load = peer; var self = this; - peer.once('error', function() { - // Just ignore, it will result in `close` anyway + peer.on('error', function(err) { + self.emit('error', err); }); peer.once('close', onclose); @@ -261,8 +261,8 @@ Pool.prototype._addPeer = function _addPeer(backoff) { // Create new peer on failure var self = this; - peer.once('error', function(err) { - // Just ignore, it will result in `close` anyway + peer.on('error', function(err) { + self.emit('error', err); }); peer.once('close', function() {