From 0bebd47a2401fce8040a7f458ceedf14525aba8c Mon Sep 17 00:00:00 2001
From: Robert Nagy <ronagy@icloud.com>
Date: Thu, 16 Dec 2021 14:32:02 +0100
Subject: [PATCH] stream: add isReadable helper

PR-URL: https://github.com/nodejs/node/pull/41199
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
---
 doc/api/stream.md                           | 13 +++++++++++++
 lib/internal/streams/utils.js               |  7 +++++--
 lib/internal/webstreams/readablestream.js   |  5 +++++
 lib/stream.js                               |  1 +
 test/parallel/test-whatwg-readablestream.js | 18 ++++++++++++++++--
 5 files changed, 40 insertions(+), 4 deletions(-)

diff --git a/doc/api/stream.md b/doc/api/stream.md
index e8b8b0c5ef6a4e..96bda35587d4ea 100644
--- a/doc/api/stream.md
+++ b/doc/api/stream.md
@@ -2223,6 +2223,19 @@ added: REPLACEME
 
 Returns whether the stream has encountered an error.
 
+### `stream.isReadable(stream)`
+
+<!-- YAML
+added: REPLACEME
+-->
+
+> Stability: 1 - Experimental
+
+* `stream` {Readable|Duplex|ReadableStream}
+* Returns: {boolean}
+
+Returns whether the stream is readable.
+
 ### `stream.Readable.toWeb(streamReadable)`
 
 <!-- YAML
diff --git a/lib/internal/streams/utils.js b/lib/internal/streams/utils.js
index f8b7ecbce74520..d81e96c63c3e96 100644
--- a/lib/internal/streams/utils.js
+++ b/lib/internal/streams/utils.js
@@ -7,6 +7,7 @@ const {
 } = primordials;
 
 const kIsErrored = Symbol('kIsErrored');
+const kIsReadable = Symbol('kIsReadable');
 const kIsDisturbed = Symbol('kIsDisturbed');
 
 function isReadableNodeStream(obj) {
@@ -119,6 +120,7 @@ function isDisturbed(stream) {
 }
 
 function isReadable(stream) {
+  if (stream && stream[kIsReadable] != null) return stream[kIsReadable];
   const r = isReadableNodeStream(stream);
   if (r === null || typeof stream?.readable !== 'boolean') return null;
   if (isDestroyed(stream)) return false;
@@ -234,15 +236,16 @@ function isErrored(stream) {
 
 module.exports = {
   isDisturbed,
-  isErrored,
   kIsDisturbed,
+  isErrored,
   kIsErrored,
+  isReadable,
+  kIsReadable,
   isClosed,
   isDestroyed,
   isDuplexNodeStream,
   isFinished,
   isIterable,
-  isReadable,
   isReadableNodeStream,
   isReadableEnded,
   isReadableFinished,
diff --git a/lib/internal/webstreams/readablestream.js b/lib/internal/webstreams/readablestream.js
index b69a77325589cc..faf14dd86a4a9a 100644
--- a/lib/internal/webstreams/readablestream.js
+++ b/lib/internal/webstreams/readablestream.js
@@ -83,6 +83,7 @@ const {
 const {
   kIsDisturbed,
   kIsErrored,
+  kIsReadable,
 } = require('internal/streams/utils');
 
 const {
@@ -246,6 +247,10 @@ class ReadableStream {
     return this[kState].state === 'errored';
   }
 
+  get [kIsReadable]() {
+    return this[kState].state === 'readable';
+  }
+
   /**
    * @readonly
    * @type {boolean}
diff --git a/lib/stream.js b/lib/stream.js
index 0c94011a532bd1..25dd9f0ba52985 100644
--- a/lib/stream.js
+++ b/lib/stream.js
@@ -44,6 +44,7 @@ const utils = require('internal/streams/utils');
 const Stream = module.exports = require('internal/streams/legacy').Stream;
 Stream.isDisturbed = utils.isDisturbed;
 Stream.isErrored = utils.isErrored;
+Stream.isReadable = utils.isReadable;
 Stream.Readable = require('internal/streams/readable');
 for (const key of ObjectKeys(operators)) {
   const op = operators[key];
diff --git a/test/parallel/test-whatwg-readablestream.js b/test/parallel/test-whatwg-readablestream.js
index b5cb94d043b59b..d27abdc75cea03 100644
--- a/test/parallel/test-whatwg-readablestream.js
+++ b/test/parallel/test-whatwg-readablestream.js
@@ -2,7 +2,7 @@
 'use strict';
 
 const common = require('../common');
-const { isDisturbed, isErrored } = require('stream');
+const { isDisturbed, isErrored, isReadable } = require('stream');
 const assert = require('assert');
 const {
   isPromise,
@@ -1573,7 +1573,6 @@ class Source {
   })().then(common.mustCall());
 }
 
-
 {
   const stream = new ReadableStream({
     pull: common.mustCall((controller) => {
@@ -1588,3 +1587,18 @@ class Source {
     isErrored(stream, true);
   })().then(common.mustCall());
 }
+
+{
+  const stream = new ReadableStream({
+    pull: common.mustCall((controller) => {
+      controller.error(new Error());
+    }),
+  });
+
+  const reader = stream.getReader();
+  (async () => {
+    isReadable(stream, true);
+    await reader.read().catch(common.mustCall());
+    isReadable(stream, false);
+  })().then(common.mustCall());
+}