@@ -864,6 +864,10 @@ OutgoingMessage..write = function write(chunk, encoding, callback) {
 };
 
 function onError(msg, err, callback) {
+if (msg.destroyed) {
+return;
+}
+
 const triggerAsyncId = msg.socket ? msg.socket[async_id_symbol] : undefined;
 defaultTriggerAsyncIdScope(triggerAsyncId,
 process.nextTick,
@@ -875,7 +879,7 @@ function onError(msg, err, callback) {
 
 function emitErrorNt(msg, err, callback) {
 callback(err);
-if (typeof msg.emit === 'function' && !msg._closed) {
+if (typeof msg.emit === 'function' && !msg.destroyed) {
 msg.emit('error', err);
 }
 }

@@ -51,5 +51,27 @@ const assert = require('assert');
 .on('error', common.mustCall())
 .write('asd');
 });
+}
 
+{
+const server = http.createServer(common.mustCall((req, res) => {
+assert.strictEqual(res.closed, false);
+res.end();
+res.destroy();
+// Make sure not to emit 'error' after .destroy().
+res.end('asd');
+assert.strictEqual(res.errored, undefined);
+})).listen(0, () => {
+http
+.request({
+port: server.address().port,
+method: 'GET'
+})
+.on('response', common.mustCall((res) => {
+res.resume().on('end', common.mustCall(() => {
+server.close();
+}));
+}))
+.end();
+});
 }