File tree Expand file tree Collapse file tree 1 file changed +16
-9
lines changed
packages/firestore/test/integration/remote Expand file tree Collapse file tree 1 file changed +16
-9
lines changed Original file line number Diff line number Diff line change @@ -226,12 +226,16 @@ describe('Write Stream', () => {
226
226
writeStream . writeHandshake ( ) ;
227
227
return streamListener . awaitCallback ( 'handshakeComplete' ) ;
228
228
} )
229
- . then ( ( ) => queue . awaitIdleTimeout ( ( ) => {
230
- writeStream . markIdle ( ) ;
231
- return streamListener . awaitCallback ( 'close' ) ;
232
- } ) . then ( ( ) => {
233
- expect ( writeStream . isOpen ( ) ) . to . be . false ;
234
- } ) ) ;
229
+ . then ( ( ) =>
230
+ queue
231
+ . awaitIdleTimeout ( ( ) => {
232
+ writeStream . markIdle ( ) ;
233
+ return streamListener . awaitCallback ( 'close' ) ;
234
+ } )
235
+ . then ( ( ) => {
236
+ expect ( writeStream . isOpen ( ) ) . to . be . false ;
237
+ } )
238
+ ) ;
235
239
} ) ;
236
240
237
241
asyncIt ( 'cancels idle on write' , ( ) => {
@@ -248,14 +252,17 @@ describe('Write Stream', () => {
248
252
writeStream . writeHandshake ( ) ;
249
253
return streamListener . awaitCallback ( 'handshakeComplete' ) ;
250
254
} )
251
- . then ( ( ) => queue . awaitIdleTimeout ( ( ) => {
255
+ . then ( ( ) =>
256
+ queue
257
+ . awaitIdleTimeout ( ( ) => {
252
258
// Mark the stream idle, but immediately cancel the idle timer by issuing another write.
253
259
writeStream . markIdle ( ) ;
254
260
writeStream . writeMutations ( SINGLE_MUTATION ) ;
255
261
return streamListener . awaitCallback ( 'mutationResult' ) ;
256
262
} )
257
263
. then ( ( ) => {
258
264
expect ( writeStream . isOpen ( ) ) . to . be . true ;
259
- } ) ) ;
260
- } ) ;
265
+ } )
266
+ ) ;
267
+ } ) ;
261
268
} ) ;
You can’t perform that action at this time.
0 commit comments