@@ -4,9 +4,9 @@ const assert = require('assert');
4
4
5
5
const { Readable, Writable } = require ( 'stream' ) ;
6
6
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 : ( ) => { } } ) ;
10
10
11
11
source . pipe ( dest1 ) ;
12
12
source . pipe ( dest2 ) ;
@@ -34,9 +34,9 @@ assert.strictEqual(source._readableState.pipes.length, 0);
34
34
35
35
{
36
36
// 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 : ( ) => { } } ) ;
40
40
41
41
let destCount = 0 ;
42
42
const srcCheckEventNames = [ 'end' , 'data' ] ;
@@ -45,13 +45,12 @@ assert.strictEqual(source._readableState.pipes.length, 0);
45
45
const checkSrcCleanup = common . mustCall ( ( ) => {
46
46
assert . strictEqual ( source . _readableState . pipes . length , 0 ) ;
47
47
assert . strictEqual ( source . _readableState . flowing , false ) ;
48
-
49
- srcCheckEventNames . forEach ( ( eventName ) => {
48
+ for ( let eventName of srcCheckEventNames ) {
50
49
assert . strictEqual (
51
50
source . listenerCount ( eventName ) , 0 ,
52
51
`source's '${ eventName } ' event listeners not removed`
53
52
) ;
54
- } ) ;
53
+ }
55
54
} ) ;
56
55
57
56
function checkDestCleanup ( dest ) {
@@ -65,13 +64,13 @@ assert.strictEqual(source._readableState.pipes.length, 0);
65
64
'listener which is `unpipeChecker`'
66
65
) ;
67
66
dest . removeListener ( 'unpipe' , unpipeChecker ) ;
68
- destCheckEventNames . forEach ( ( eventName ) => {
67
+ for ( const eventName of destCheckEventNames ) {
69
68
assert . strictEqual (
70
69
dest . listenerCount ( eventName ) , 0 ,
71
70
`destination{${ currentDestId } }'s '${ eventName } ' event ` +
72
71
'listeners not removed'
73
72
) ;
74
- } ) ;
73
+ }
75
74
76
75
if ( -- destCount === 0 )
77
76
checkSrcCleanup ( ) ;
@@ -86,8 +85,8 @@ assert.strictEqual(source._readableState.pipes.length, 0);
86
85
}
87
86
88
87
{
89
- const src = Readable ( { read : ( ) => { } } ) ;
90
- const dst = Writable ( { write : ( ) => { } } ) ;
88
+ const src = Readable ( { read : ( ) => { } } ) ;
89
+ const dst = Writable ( { write : ( ) => { } } ) ;
91
90
src . pipe ( dst ) ;
92
91
src . on ( 'resume' , common . mustCall ( ( ) => {
93
92
src . on ( 'pause' , common . mustCall ( ) ) ;
0 commit comments