nodejs
diff --git a/‎lib/_stream_readable.js‎
Lines changed: 6 additions & 1 deletion b/‎lib/_stream_readable.js‎
Lines changed: 6 additions & 1 deletion
diff --git a/‎lib/internal/streams/destroy.js‎
Lines changed: 6 additions & 1 deletion b/‎lib/internal/streams/destroy.js‎
Lines changed: 6 additions & 1 deletion
diff --git a/‎test/parallel/test-stream-duplex-destroy.js‎
Lines changed: 1 addition & 1 deletion b/‎test/parallel/test-stream-duplex-destroy.js‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎test/parallel/test-stream-readable-destroy.js‎
Lines changed: 1 addition & 1 deletion b/‎test/parallel/test-stream-readable-destroy.js‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎test/parallel/test-stream-readable-end-destroyed.js‎
Lines changed: 17 additions & 0 deletions b/‎test/parallel/test-stream-readable-end-destroyed.js‎
Lines changed: 17 additions & 0 deletions
@@ -150,6 +150,10 @@ function ReadableState(options, stream, isDuplex) {
   // Indicates whether the stream has finished destroying.
   this.closed = false;
 
+  // True if close has been emitted or would have been emitted
+  // depending on emitClose.
+  this.closeEmitted = false;
+
   // Crypto is kind of old and crusty.  Historically, its default string
   // encoding is 'binary' so we have to make this configurable.
   // Everything else in the universe uses 'utf8', though.
@@ -1213,7 +1217,8 @@ function endReadableNT(state, stream) {
   debug('endReadableNT', state.endEmitted, state.length);
 
   // Check that we didn't get one last unshift.
-  if (!state.errorEmitted && !state.endEmitted && state.length === 0) {
+  if (!state.errorEmitted && !state.closeEmitted &&
+      !state.endEmitted && state.length === 0) {
     state.endEmitted = true;
     stream.emit('end');
 
 
@@ -73,6 +73,10 @@ function emitCloseNT(self) {
   const r = self._readableState;
   const w = self._writableState;
 
+  if (r) {
+    r.closeEmitted = true;
+  }
+
   if ((w && w.emitClose) || (r && r.emitClose)) {
     self.emit('close');
   }
@@ -102,12 +106,13 @@ function undestroy() {
 
   if (r) {
     r.closed = false;
+    r.closeEmitted = false;
     r.destroyed = false;
     r.errored = false;
+    r.errorEmitted = false;
     r.reading = false;
     r.ended = false;
     r.endEmitted = false;
-    r.errorEmitted = false;
   }
 
   if (w) {
 
@@ -124,7 +124,7 @@ const assert = require('assert');
 
   duplex.removeListener('end', fail);
   duplex.removeListener('finish', fail);
-  duplex.on('end', common.mustCall());
+  duplex.on('end', common.mustNotCall());
   duplex.on('finish', common.mustCall());
   assert.strictEqual(duplex.destroyed, true);
 }
 
@@ -113,7 +113,7 @@ const assert = require('assert');
   read.destroy();
 
   read.removeListener('end', fail);
-  read.on('end', common.mustCall());
+  read.on('end', common.mustNotCall());
   assert.strictEqual(read.destroyed, true);
 }
 
 
@@ -0,0 +1,17 @@
+'use strict';
+
+const common = require('../common');
+const { Readable } = require('stream');
+
+{
+  // Don't emit 'end' after 'close'.
+
+  const r = new Readable();
+
+  r.on('end', common.mustNotCall());
+  r.resume();
+  r.destroy();
+  r.on('close', common.mustCall(() => {
+    r.push(null);
+  }));
+}
Original file line number	Diff line number	Diff line change
@@ -124,7 +124,7 @@ const assert = require('assert');
124	124
125	125	duplex.removeListener('end', fail);
126	126	duplex.removeListener('finish', fail);
127		- duplex.on('end', common.mustCall());
	127	+ duplex.on('end', common.mustNotCall());
128	128	duplex.on('finish', common.mustCall());
129	129	assert.strictEqual(duplex.destroyed, true);
130	130	}
Original file line number	Diff line number	Diff line change
@@ -113,7 +113,7 @@ const assert = require('assert');
113	113	read.destroy();
114	114
115	115	read.removeListener('end', fail);
116		- read.on('end', common.mustCall());
	116	+ read.on('end', common.mustNotCall());
117	117	assert.strictEqual(read.destroyed, true);
118	118	}
119	119