1'use strict';
2// https://github.com/nodejs/node/issues/35926
3const common = require('../common');
4const assert = require('assert');
5const stream = require('stream');
6
7let loops = 5;
8
9const src = new stream.Readable({
10  read() {
11    if (loops--)
12      this.push(Buffer.alloc(20000));
13  }
14});
15
16const dst = new stream.Transform({
17  transform(chunk, output, fn) {
18    this.push(null);
19    fn();
20  }
21});
22
23src.pipe(dst);
24
25dst.on('data', () => { });
26dst.on('end', common.mustCall(() => {
27  assert.strictEqual(loops, 3);
28  assert.ok(src.isPaused());
29}));
30