'use strict'; const common = require('../common'); const { Readable } = require('stream'); // readable.resume() should not lead to a ._read() call being scheduled // when we exceed the high water mark already. const readable = new Readable({ read: common.mustNotCall(), highWaterMark: 100 }); // Fill up the internal buffer so that we definitely exceed the HWM: for (let i = 0; i < 10; i++) readable.push('a'.repeat(200)); // Call resume, and pause after one chunk. // The .pause() is just so that we don’t empty the buffer fully, which would // be a valid reason to call ._read(). readable.resume(); readable.once('data', common.mustCall(() => readable.pause()));