@@ -89,9 +89,7 @@ describe('createParallelWorker', () => {
8989 } ,
9090 ] ;
9191
92- const chunks = await collectChunks (
93- worker . stream ( mockInput , { typeMap : { } } )
94- ) ;
92+ const chunks = await collectChunks ( worker . stream ( mockInput , { } ) ) ;
9593
9694 strictEqual ( chunks . length , 4 ) ;
9795
@@ -120,9 +118,7 @@ describe('createParallelWorker', () => {
120118 } ,
121119 ] ;
122120
123- const chunks = await collectChunks (
124- worker . stream ( mockInput , { typeMap : { } } )
125- ) ;
121+ const chunks = await collectChunks ( worker . stream ( mockInput , { } ) ) ;
126122
127123 strictEqual ( chunks . length , 2 ) ;
128124
@@ -143,9 +139,7 @@ describe('createParallelWorker', () => {
143139 } ,
144140 ] ;
145141
146- const chunks = await collectChunks (
147- worker . stream ( mockInput , { typeMap : { } } )
148- ) ;
142+ const chunks = await collectChunks ( worker . stream ( mockInput , { } ) ) ;
149143
150144 strictEqual ( chunks . length , 1 ) ;
151145 ok ( Array . isArray ( chunks [ 0 ] ) ) ;
@@ -171,9 +165,7 @@ describe('createParallelWorker', () => {
171165 } ,
172166 ] ;
173167
174- const chunks = await collectChunks (
175- worker . stream ( mockInput , { typeMap : { } } )
176- ) ;
168+ const chunks = await collectChunks ( worker . stream ( mockInput , { } ) ) ;
177169
178170 strictEqual ( chunks . length , 2 ) ;
179171
0 commit comments