@@ -908,6 +908,10 @@ OutgoingMessage.prototype.write = function write(chunk, encoding, callback) {
|
908 | 908 | }; |
909 | 909 | |
910 | 910 | function onError(msg, err, callback) { |
| 911 | +if (msg.destroyed) { |
| 912 | +return; |
| 913 | +} |
| 914 | + |
911 | 915 | const triggerAsyncId = msg.socket ? msg.socket[async_id_symbol] : undefined; |
912 | 916 | defaultTriggerAsyncIdScope(triggerAsyncId, |
913 | 917 | process.nextTick, |
@@ -919,7 +923,7 @@ function onError(msg, err, callback) {
|
919 | 923 | |
920 | 924 | function emitErrorNt(msg, err, callback) { |
921 | 925 | callback(err); |
922 | | -if (typeof msg.emit === 'function' && !msg._closed) { |
| 926 | +if (typeof msg.emit === 'function' && !msg.destroyed) { |
923 | 927 | msg.emit('error', err); |
924 | 928 | } |
925 | 929 | } |
|