From c446fcd6fc1ad6b5f7b488caa1d562411992d7be Mon Sep 17 00:00:00 2001
From: Robert Nagy <ronagy@icloud.com>
Date: Tue, 23 Jul 2019 09:40:13 +0200
Subject: [PATCH 1/4] stream: add readableEnded

---
 doc/api/stream.md                           |  9 ++++++
 lib/_stream_readable.js                     | 10 +++++++
 lib/internal/streams/end-of-stream.js       |  3 +-
 test/parallel/test-stream-readable-ended.js | 33 +++++++++++++++++++++
 4 files changed, 54 insertions(+), 1 deletion(-)
 create mode 100644 test/parallel/test-stream-readable-ended.js

diff --git a/doc/api/stream.md b/doc/api/stream.md
index 2cdd6ffde31b29..91d253b067f6df 100644
--- a/doc/api/stream.md
+++ b/doc/api/stream.md
@@ -1095,6 +1095,15 @@ added: REPLACEME
 Getter for the property `encoding` of a given `Readable` stream. The `encoding`
 property can be set using the [`readable.setEncoding()`][] method.
 
+##### readable.readableFinished
+<!-- YAML
+added: REPLACEME
+-->
+
+* {boolean}
+
+Becomes `true` when [`'end'`][] event is emitted.
+
 ##### readable.readableHighWaterMark
 <!-- YAML
 added: v9.3.0
diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
index 5b73646db809c2..41f5ed09b5329f 100644
--- a/lib/_stream_readable.js
+++ b/lib/_stream_readable.js
@@ -202,6 +202,16 @@ Object.defineProperty(Readable.prototype, 'destroyed', {
   }
 });
 
+Object.defineProperty(Readable.prototype, 'readableEnded', {
+  // Making it explicit this property is not enumerable
+  // because otherwise some prototype manipulation in
+  // userland will fail
+  enumerable: false,
+  get() {
+    return this._readableState.endEmitted;
+  }
+});
+
 Readable.prototype.destroy = destroyImpl.destroy;
 Readable.prototype._undestroy = destroyImpl.undestroy;
 Readable.prototype._destroy = function(err, cb) {
diff --git a/lib/internal/streams/end-of-stream.js b/lib/internal/streams/end-of-stream.js
index 1753996a4f85de..850e5d3796c448 100644
--- a/lib/internal/streams/end-of-stream.js
+++ b/lib/internal/streams/end-of-stream.js
@@ -42,7 +42,8 @@ function eos(stream, opts, callback) {
     if (!readable) callback.call(stream);
   };
 
-  var readableEnded = stream._readableState && stream._readableState.endEmitted;
+  var readableEnded = stream.readableEnded ||
+    (stream._readableState && stream._readableState.endEmitted);
   const onend = () => {
     readable = false;
     readableEnded = true;
diff --git a/test/parallel/test-stream-readable-ended.js b/test/parallel/test-stream-readable-ended.js
new file mode 100644
index 00000000000000..46987deac47c12
--- /dev/null
+++ b/test/parallel/test-stream-readable-ended.js
@@ -0,0 +1,33 @@
+'use strict';
+
+const common = require('../common');
+const { Readable } = require('stream');
+const assert = require('assert');
+
+// basic
+{
+  // Find it on Readable.prototype
+  assert(Readable.prototype.hasOwnProperty('readableEnded'));
+}
+
+// event
+{
+  const readable = new Readable();
+
+  readable._read = () => {
+    // The state finished should start in false.
+    assert.strictEqual(readable.readableEnded, false);
+    readable.push('asd');
+    assert.strictEqual(readable.readableEnded, false);
+    readable.push(null);
+    assert.strictEqual(readable.readableEnded, false);
+  };
+
+  readable.on('end', common.mustCall(() => {
+    assert.strictEqual(readable.readableEnded, true);
+  }));
+
+  readable.on('data', common.mustCall(() => {
+    assert.strictEqual(readable.readableEnded, false);
+  }));
+}

From dd03ec5689671a7e8c53a17ef33f35e7919493b3 Mon Sep 17 00:00:00 2001
From: Robert Nagy <ronagy@icloud.com>
Date: Tue, 23 Jul 2019 20:00:22 +0200
Subject: [PATCH 2/4] Update lib/_stream_readable.js

Co-Authored-By: Luigi Pinca <luigipinca@gmail.com>
---
 lib/_stream_readable.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
index 41f5ed09b5329f..173c4c04795d6d 100644
--- a/lib/_stream_readable.js
+++ b/lib/_stream_readable.js
@@ -208,7 +208,7 @@ Object.defineProperty(Readable.prototype, 'readableEnded', {
   // userland will fail
   enumerable: false,
   get() {
-    return this._readableState.endEmitted;
+    return this._readableState ? this._readableState.endEmitted : false;
   }
 });
 

From a51944f51e08040d4d48e5a346b3f12e762898d8 Mon Sep 17 00:00:00 2001
From: Robert Nagy <ronagy@icloud.com>
Date: Fri, 26 Jul 2019 23:39:53 +0300
Subject: [PATCH 3/4] Update doc/api/stream.md

Co-Authored-By: Matteo Collina <matteo.collina@gmail.com>
---
 doc/api/stream.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/doc/api/stream.md b/doc/api/stream.md
index 91d253b067f6df..eb92f23b6d9fc0 100644
--- a/doc/api/stream.md
+++ b/doc/api/stream.md
@@ -1095,7 +1095,7 @@ added: REPLACEME
 Getter for the property `encoding` of a given `Readable` stream. The `encoding`
 property can be set using the [`readable.setEncoding()`][] method.
 
-##### readable.readableFinished
+##### readable.readableEnded
 <!-- YAML
 added: REPLACEME
 -->

From e54d0109dfa653af8590ae4232d92a4d77f92bfa Mon Sep 17 00:00:00 2001
From: Robert Nagy <ronagy@icloud.com>
Date: Sat, 27 Jul 2019 15:28:48 +0300
Subject: [PATCH 4/4] Update test/parallel/test-stream-readable-ended.js

Co-Authored-By: Vitaly Kuzmich <wanadoo.by@gmail.com>
---
 lib/internal/streams/async_iterator.js      | 2 +-
 test/parallel/test-stream-finished.js       | 9 +++++++++
 test/parallel/test-stream-readable-ended.js | 2 +-
 3 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/lib/internal/streams/async_iterator.js b/lib/internal/streams/async_iterator.js
index 89a1dae7fdfb02..0161ca98ef03fb 100644
--- a/lib/internal/streams/async_iterator.js
+++ b/lib/internal/streams/async_iterator.js
@@ -132,7 +132,7 @@ const createReadableStreamAsyncIterator = (stream) => {
     [kLastReject]: { value: null, writable: true },
     [kError]: { value: null, writable: true },
     [kEnded]: {
-      value: stream._readableState.endEmitted,
+      value: stream.readableEnded || stream._readableState.endEmitted,
       writable: true
     },
     // The function passed to new Promise is cached so we avoid allocating a new
diff --git a/test/parallel/test-stream-finished.js b/test/parallel/test-stream-finished.js
index 329b4ed42b0c43..d6361ea303635d 100644
--- a/test/parallel/test-stream-finished.js
+++ b/test/parallel/test-stream-finished.js
@@ -3,6 +3,7 @@
 const common = require('../common');
 const { Writable, Readable, Transform, finished } = require('stream');
 const assert = require('assert');
+const EE = require('events');
 const fs = require('fs');
 const { promisify } = require('util');
 
@@ -175,3 +176,11 @@ const { promisify } = require('util');
   rs.push(null);
   rs.resume();
 }
+
+{
+  const streamLike = new EE();
+  streamLike.readableEnded = true;
+  streamLike.readable = true;
+  finished(streamLike, common.mustCall);
+  streamLike.emit('close');
+}
diff --git a/test/parallel/test-stream-readable-ended.js b/test/parallel/test-stream-readable-ended.js
index 46987deac47c12..a224c68f041d10 100644
--- a/test/parallel/test-stream-readable-ended.js
+++ b/test/parallel/test-stream-readable-ended.js
@@ -15,7 +15,7 @@ const assert = require('assert');
   const readable = new Readable();
 
   readable._read = () => {
-    // The state finished should start in false.
+    // The state ended should start in false.
     assert.strictEqual(readable.readableEnded, false);
     readable.push('asd');
     assert.strictEqual(readable.readableEnded, false);