Merge pull request #22 from chjj/parser-errors
pool: stop throwing uncatchable errors on parser errors.
This commit is contained in:
commit
fbb3660361
@ -118,8 +118,8 @@ Pool.prototype._addLoader = function _addLoader() {
|
|||||||
this.peers.load = peer;
|
this.peers.load = peer;
|
||||||
|
|
||||||
var self = this;
|
var self = this;
|
||||||
peer.once('error', function() {
|
peer.on('error', function(err) {
|
||||||
// Just ignore, it will result in `close` anyway
|
self.emit('error', err);
|
||||||
});
|
});
|
||||||
|
|
||||||
peer.once('close', onclose);
|
peer.once('close', onclose);
|
||||||
@ -261,8 +261,8 @@ Pool.prototype._addPeer = function _addPeer(backoff) {
|
|||||||
|
|
||||||
// Create new peer on failure
|
// Create new peer on failure
|
||||||
var self = this;
|
var self = this;
|
||||||
peer.once('error', function(err) {
|
peer.on('error', function(err) {
|
||||||
// Just ignore, it will result in `close` anyway
|
self.emit('error', err);
|
||||||
});
|
});
|
||||||
|
|
||||||
peer.once('close', function() {
|
peer.once('close', function() {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user