diff --git a/test/parallel/test-stream-pipe-await-drain-push-while-write.js b/test/parallel/test-stream-pipe-await-drain-push-while-write.js index 263e6b6801f68b..d14ad46cb066ec 100644 --- a/test/parallel/test-stream-pipe-await-drain-push-while-write.js +++ b/test/parallel/test-stream-pipe-await-drain-push-while-write.js @@ -7,8 +7,7 @@ const writable = new stream.Writable({ write: common.mustCall(function(chunk, encoding, cb) { assert.strictEqual( readable._readableState.awaitDrain, - 0, - 'State variable awaitDrain is not correct.' + 0 ); if (chunk.length === 32 * 1024) { // first chunk @@ -16,8 +15,7 @@ const writable = new stream.Writable({ // We should check if awaitDrain counter is increased in the next // tick, because awaitDrain is incremented after this method finished process.nextTick(() => { - assert.strictEqual(readable._readableState.awaitDrain, 1, - 'Counter is not increased for awaitDrain'); + assert.strictEqual(readable._readableState.awaitDrain, 1); }); }