From 25d6eed6540c87615156f396d3b56c4588eca4e1 Mon Sep 17 00:00:00 2001
From: Gregory <gregory.petrosyan@mail.utoronto.ca>
Date: Thu, 1 Dec 2016 01:52:23 -0500
Subject: [PATCH] test: stream readableState readingMore state

PR-URL: https://github.com/nodejs/node/pull/9868
Refs: https://github.com/nodejs/node/issues/8685
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Italo A. Casas <me@italoacasas.com>
---
 ...est-stream-readable-reading-readingMore.js | 65 +++++++++++++++++++
 1 file changed, 65 insertions(+)
 create mode 100644 test/parallel/test-stream-readable-reading-readingMore.js

diff --git a/test/parallel/test-stream-readable-reading-readingMore.js b/test/parallel/test-stream-readable-reading-readingMore.js
new file mode 100644
index 0000000000..bee3a1c82a
--- /dev/null
+++ b/test/parallel/test-stream-readable-reading-readingMore.js
@@ -0,0 +1,65 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const Readable = require('stream').Readable;
+
+const readable = new Readable({
+  read(size) {}
+});
+
+const state = readable._readableState;
+
+// Starting off with false initially.
+assert.strictEqual(state.reading, false);
+assert.strictEqual(state.readingMore, false);
+
+readable.on('data', common.mustCall((data) => {
+  // while in a flowing state, should try to read more.
+  if (state.flowing)
+    assert.strictEqual(state.readingMore, true);
+
+  // reading as long as we've not ended
+  assert.strictEqual(state.reading, !state.ended);
+}, 2));
+
+function onStreamEnd() {
+  // End of stream; state.reading is false
+  // And so should be readingMore.
+  assert.strictEqual(state.readingMore, false);
+  assert.strictEqual(state.reading, false);
+}
+
+readable.on('readable', common.mustCall(() => {
+  // 'readable' always gets called before 'end'
+  // since 'end' hasn't been emitted, more data could be incoming
+  assert.strictEqual(state.readingMore, true);
+
+  // if the stream has ended, we shouldn't be reading
+  assert.strictEqual(state.ended, !state.reading);
+
+  if (readable.read() === null) // reached end of stream
+    process.nextTick(common.mustCall(onStreamEnd, 1));
+}, 2));
+
+readable.on('end', common.mustCall(onStreamEnd));
+
+readable.push('pushed');
+
+// stop emitting 'data' events
+readable.pause();
+
+// read() should only be called while operating in paused mode
+readable.read(6);
+
+// reading
+assert.strictEqual(state.reading, true);
+assert.strictEqual(state.readingMore, true);
+
+// resume emitting 'data' events
+readable.resume();
+
+// add chunk to front
+readable.unshift('unshifted');
+
+// end
+readable.push(null);