summaryrefslogtreecommitdiff
path: root/test/parallel/test-stream2-large-read-stall.js
diff options
context:
space:
mode:
Diffstat (limited to 'test/parallel/test-stream2-large-read-stall.js')
-rw-r--r--test/parallel/test-stream2-large-read-stall.js8
1 files changed, 3 insertions, 5 deletions
diff --git a/test/parallel/test-stream2-large-read-stall.js b/test/parallel/test-stream2-large-read-stall.js
index 36d4e0c6c9..2422747f82 100644
--- a/test/parallel/test-stream2-large-read-stall.js
+++ b/test/parallel/test-stream2-large-read-stall.js
@@ -33,7 +33,9 @@ r.on('readable', function() {
rs.length);
});
-r.on('end', common.mustCall(function() {}));
+r.on('end', common.mustCall(function() {
+ assert.strictEqual(pushes, PUSHCOUNT + 1);
+}));
let pushes = 0;
function push() {
@@ -49,7 +51,3 @@ function push() {
if (r.push(Buffer.allocUnsafe(PUSHSIZE)))
setTimeout(push, 1);
}
-
-process.on('exit', function() {
- assert.strictEqual(pushes, PUSHCOUNT + 1);
-});