@@ -864,6 +864,10 @@ OutgoingMessage.prototype.write = function write(chunk, encoding, callback) {
|
864 | 864 | }; |
865 | 865 | |
866 | 866 | function onError(msg, err, callback) { |
| 867 | +if (msg.destroyed) { |
| 868 | +return; |
| 869 | +} |
| 870 | + |
867 | 871 | const triggerAsyncId = msg.socket ? msg.socket[async_id_symbol] : undefined; |
868 | 872 | defaultTriggerAsyncIdScope(triggerAsyncId, |
869 | 873 | process.nextTick, |
@@ -875,7 +879,7 @@ function onError(msg, err, callback) {
|
875 | 879 | |
876 | 880 | function emitErrorNt(msg, err, callback) { |
877 | 881 | callback(err); |
878 | | -if (typeof msg.emit === 'function' && !msg._closed) { |
| 882 | +if (typeof msg.emit === 'function' && !msg.destroyed) { |
879 | 883 | msg.emit('error', err); |
880 | 884 | } |
881 | 885 | } |
|