@@ -1470,7 +1470,7 @@ describeSpec('Writes:', [], () => {
1470
1470
. addSnapshotsInSyncListener ( )
1471
1471
. expectSnapshotsInSyncEventsCount ( 1 )
1472
1472
. userSets ( 'collection/a' , { v : 2 } )
1473
- . expectSnapshotsInSyncEventsCount ( 1 ) ;
1473
+ . expectSnapshotsInSyncEventsCount ( 0 ) ;
1474
1474
}
1475
1475
) ;
1476
1476
@@ -1482,7 +1482,7 @@ describeSpec('Writes:', [], () => {
1482
1482
. addSnapshotsInSyncListener ( )
1483
1483
. expectSnapshotsInSyncEventsCount ( 1 )
1484
1484
. addSnapshotsInSyncListener ( )
1485
- . expectSnapshotsInSyncEventsCount ( 2 ) ;
1485
+ . expectSnapshotsInSyncEventsCount ( 1 ) ;
1486
1486
}
1487
1487
) ;
1488
1488
@@ -1508,19 +1508,19 @@ describeSpec('Writes:', [], () => {
1508
1508
hasPendingWrites : true ,
1509
1509
modified : [ docAv2Local ]
1510
1510
} )
1511
- . expectSnapshotsInSyncEventsCount ( 2 )
1511
+ . expectSnapshotsInSyncEventsCount ( 1 )
1512
1512
. watchSends ( { affects : [ query ] } , docAv2 )
1513
1513
. watchSnapshots ( 2000 )
1514
1514
. writeAcks ( 'collection/a' , 2000 )
1515
1515
. expectEvents ( query , {
1516
1516
metadata : [ docAv2 ]
1517
1517
} )
1518
- . expectSnapshotsInSyncEventsCount ( 3 ) ;
1518
+ . expectSnapshotsInSyncEventsCount ( 1 ) ;
1519
1519
} ) ;
1520
1520
1521
1521
specTest (
1522
1522
'onSnapshotInSync fires once for multiple event snapshots' ,
1523
- [ 'exclusive' ] ,
1523
+ [ ] ,
1524
1524
( ) => {
1525
1525
const query1 = Query . atPath ( path ( 'collection' ) ) ;
1526
1526
const query2 = Query . atPath ( path ( 'collection/a' ) ) ;
@@ -1552,7 +1552,7 @@ describeSpec('Writes:', [], () => {
1552
1552
hasPendingWrites : true ,
1553
1553
modified : [ docAv2Local ]
1554
1554
} )
1555
- . expectSnapshotsInSyncEventsCount ( 2 )
1555
+ . expectSnapshotsInSyncEventsCount ( 1 )
1556
1556
. watchSends ( { affects : [ query1 , query2 ] } , docAv2 )
1557
1557
. watchSnapshots ( 2000 )
1558
1558
. writeAcks ( 'collection/a' , 2000 )
@@ -1562,7 +1562,7 @@ describeSpec('Writes:', [], () => {
1562
1562
. expectEvents ( query2 , {
1563
1563
metadata : [ docAv2 ]
1564
1564
} )
1565
- . expectSnapshotsInSyncEventsCount ( 3 ) ;
1565
+ . expectSnapshotsInSyncEventsCount ( 1 ) ;
1566
1566
}
1567
1567
) ;
1568
1568
@@ -1603,22 +1603,22 @@ describeSpec('Writes:', [], () => {
1603
1603
. addSnapshotsInSyncListener ( )
1604
1604
. addSnapshotsInSyncListener ( )
1605
1605
// 2 original events + 2 new events from registering listeners.
1606
- . expectSnapshotsInSyncEventsCount ( 4 )
1606
+ . expectSnapshotsInSyncEventsCount ( 2 )
1607
1607
. userSets ( 'collection/a' , { v : 3 } )
1608
1608
. expectEvents ( query , {
1609
1609
hasPendingWrites : true ,
1610
1610
modified : [ docAv3Local ]
1611
1611
} )
1612
1612
// 4 original events + 3 new events from the 3 listeners
1613
- . expectSnapshotsInSyncEventsCount ( 7 )
1613
+ . expectSnapshotsInSyncEventsCount ( 3 )
1614
1614
. removeSnapshotsInSyncListener ( )
1615
1615
. userSets ( 'collection/a' , { v : 4 } )
1616
1616
. expectEvents ( query , {
1617
1617
hasPendingWrites : true ,
1618
1618
modified : [ docAv4Local ]
1619
1619
} )
1620
1620
// 7 original events + 2 new events from the 2 listeners
1621
- . expectSnapshotsInSyncEventsCount ( 9 )
1621
+ . expectSnapshotsInSyncEventsCount ( 2 )
1622
1622
) ;
1623
1623
} ) ;
1624
1624
} ) ;
0 commit comments