@@ -4,9 +4,9 @@ const assert = require('assert');
44
55const { Readable, Writable } = require ( 'stream' ) ;
66
7- const source = Readable ( { read : ( ) => { } } ) ;
8- const dest1 = Writable ( { write : ( ) => { } } ) ;
9- const dest2 = Writable ( { write : ( ) => { } } ) ;
7+ const source = Readable ( { read : ( ) => { } } ) ;
8+ const dest1 = Writable ( { write : ( ) => { } } ) ;
9+ const dest2 = Writable ( { write : ( ) => { } } ) ;
1010
1111source . pipe ( dest1 ) ;
1212source . pipe ( dest2 ) ;
@@ -34,9 +34,9 @@ assert.strictEqual(source._readableState.pipes.length, 0);
3434
3535{
3636 // Test `cleanup()` if we unpipe all streams.
37- const source = Readable ( { read : ( ) => { } } ) ;
38- const dest1 = Writable ( { write : ( ) => { } } ) ;
39- const dest2 = Writable ( { write : ( ) => { } } ) ;
37+ const source = Readable ( { read : ( ) => { } } ) ;
38+ const dest1 = Writable ( { write : ( ) => { } } ) ;
39+ const dest2 = Writable ( { write : ( ) => { } } ) ;
4040
4141 let destCount = 0 ;
4242 const srcCheckEventNames = [ 'end' , 'data' ] ;
@@ -45,13 +45,12 @@ assert.strictEqual(source._readableState.pipes.length, 0);
4545 const checkSrcCleanup = common . mustCall ( ( ) => {
4646 assert . strictEqual ( source . _readableState . pipes . length , 0 ) ;
4747 assert . strictEqual ( source . _readableState . flowing , false ) ;
48-
49- srcCheckEventNames . forEach ( ( eventName ) => {
48+ for ( let eventName of srcCheckEventNames ) {
5049 assert . strictEqual (
5150 source . listenerCount ( eventName ) , 0 ,
5251 `source's '${ eventName } ' event listeners not removed`
5352 ) ;
54- } ) ;
53+ }
5554 } ) ;
5655
5756 function checkDestCleanup ( dest ) {
@@ -65,13 +64,13 @@ assert.strictEqual(source._readableState.pipes.length, 0);
6564 'listener which is `unpipeChecker`'
6665 ) ;
6766 dest . removeListener ( 'unpipe' , unpipeChecker ) ;
68- destCheckEventNames . forEach ( ( eventName ) => {
67+ for ( const eventName of destCheckEventNames ) {
6968 assert . strictEqual (
7069 dest . listenerCount ( eventName ) , 0 ,
7170 `destination{${ currentDestId } }'s '${ eventName } ' event ` +
7271 'listeners not removed'
7372 ) ;
74- } ) ;
73+ }
7574
7675 if ( -- destCount === 0 )
7776 checkSrcCleanup ( ) ;
@@ -86,8 +85,8 @@ assert.strictEqual(source._readableState.pipes.length, 0);
8685}
8786
8887{
89- const src = Readable ( { read : ( ) => { } } ) ;
90- const dst = Writable ( { write : ( ) => { } } ) ;
88+ const src = Readable ( { read : ( ) => { } } ) ;
89+ const dst = Writable ( { write : ( ) => { } } ) ;
9190 src . pipe ( dst ) ;
9291 src . on ( 'resume' , common . mustCall ( ( ) => {
9392 src . on ( 'pause' , common . mustCall ( ) ) ;
0 commit comments