@@ -350,19 +350,20 @@ describeSpec('Listens:', [], () => {
350
350
// us up to docAV2 since that's the last relevant change to the query
351
351
// (the document falls out) and send us a snapshot that's ahead of
352
352
// docAv3 (which is already in our cache).
353
- . userListens ( visibleQuery , { resumeToken : 'resume-token-4000' } )
354
- // .watchAcks(visibleQuery)
355
- // .watchSends({ removed: [visibleQuery] }, docAv2)
356
- // .watchCurrents(visibleQuery, 'resume-token-5000')
357
- // .watchSnapshots(5000)
358
- // .expectEvents(visibleQuery, { fromCache: false })
359
- // .userUnlistens(visibleQuery)
360
- // .watchRemoves(visibleQuery)
361
- // // Listen to allQuery again and make sure we still get docAv3.
362
- // .userListens(allQuery, { resumeToken: 'resume-token-4000' })
363
- // .expectEvents(allQuery, { added: [docAv3], fromCache: true })
364
- // .watchAcksFull(allQuery, 6000)
365
- // .expectEvents(allQuery, { fromCache: false })
353
+ . userListens ( visibleQuery , { resumeToken : 'resume-token-1000' } )
354
+ . expectEvents ( visibleQuery , { fromCache : true } )
355
+ . watchAcks ( visibleQuery )
356
+ . watchSends ( { removed : [ visibleQuery ] } , docAv2 )
357
+ . watchCurrents ( visibleQuery , 'resume-token-5000' )
358
+ . watchSnapshots ( 5000 )
359
+ . expectEvents ( visibleQuery , { fromCache : false } )
360
+ . userUnlistens ( visibleQuery )
361
+ . watchRemoves ( visibleQuery )
362
+ // Listen to allQuery again and make sure we still get docAv3.
363
+ . userListens ( allQuery , { resumeToken : 'resume-token-4000' } )
364
+ . expectEvents ( allQuery , { added : [ docAv3 ] , fromCache : true } )
365
+ . watchAcksFull ( allQuery , 6000 )
366
+ . expectEvents ( allQuery , { fromCache : false } )
366
367
) ;
367
368
} ) ;
368
369
@@ -396,6 +397,7 @@ describeSpec('Listens:', [], () => {
396
397
// (the document falls out) and send us a snapshot that's ahead of
397
398
// docAv3 (which is already in our cache).
398
399
. userListens ( visibleQuery , { resumeToken : 'resume-token-1000' } )
400
+ . expectEvents ( visibleQuery , { fromCache : true } )
399
401
. watchAcks ( visibleQuery )
400
402
. watchSends ( { removed : [ visibleQuery ] } , docAv2 )
401
403
. watchCurrents ( visibleQuery , 'resume-token-5000' )
@@ -405,6 +407,7 @@ describeSpec('Listens:', [], () => {
405
407
. watchRemoves ( visibleQuery )
406
408
// Listen to allQuery again and make sure we still get no docs.
407
409
. userListens ( allQuery , { resumeToken : 'resume-token-4000' } )
410
+ . expectEvents ( allQuery , { fromCache : true } )
408
411
. watchAcksFull ( allQuery , 6000 )
409
412
. expectEvents ( allQuery , { fromCache : false } )
410
413
) ;
0 commit comments