@@ -889,6 +889,7 @@ describeSpec('Limbo Documents:', [], () => {
889
889
// to just send the docBs with an existence filter with a count of 3.
890
890
. watchSends ( { affects : [ query1 ] } , docB1 , docB2 , docB3 )
891
891
. watchFilters ( [ query1 ] , [ docB1 . key , docB2 . key , docB3 . key ] )
892
+ . watchCurrents ( query1 , 'resume-token-1001' )
892
893
. watchSnapshots ( 1001 )
893
894
. expectEvents ( query1 , {
894
895
added : [ docB1 , docB2 , docB3 ] ,
@@ -968,6 +969,7 @@ describeSpec('Limbo Documents:', [], () => {
968
969
[ docB1 . key , docB2 . key , docB3 . key ] ,
969
970
bloomFilterProto
970
971
)
972
+ . watchCurrents ( query1 , 'resume-token-1001' )
971
973
. watchSnapshots ( 1001 )
972
974
. expectEvents ( query1 , {
973
975
added : [ docB1 , docB2 , docB3 ] ,
@@ -978,8 +980,6 @@ describeSpec('Limbo Documents:', [], () => {
978
980
// existence filter mismatch. Bloom filter checks membership of the
979
981
// docs, and filters out docAs, while docBs returns true. Number of
980
982
// existing docs matches the expected count, so skip the re-query.
981
- . watchCurrents ( query1 , 'resume-token-1002' )
982
- . watchSnapshots ( 1002 )
983
983
// The docAs are now in limbo; the client begins limbo resolution.
984
984
. expectLimboDocs ( docA1 . key , docA2 . key )
985
985
. expectEnqueuedLimboDocs ( docA3 . key )
0 commit comments