|
@@ -136,7 +136,6 @@ Multiplexer.prototype.ready = function(cb) {
|
136
|
136
|
Multiplexer.prototype._finalize = function(err) {
|
137
|
137
|
if (err) {
|
138
|
138
|
debug(this._id + ' [REPLICATION] destroyed due to', err)
|
139
|
|
- this.emit('error', err)
|
140
|
139
|
this.stream.destroy(err)
|
141
|
140
|
} else {
|
142
|
141
|
debug(this._id + ' [REPLICATION] finalized', err)
|