@@ -237,7 +237,7 @@ describe(`Query Index Optimization`, () => {
237
237
getKey : ( item ) => item . id ,
238
238
startSync : true ,
239
239
sync : {
240
- sync : ( { begin, write, commit } ) => {
240
+ sync : ( { begin, write, commit, markReady } ) => {
241
241
// Provide initial data through sync
242
242
begin ( )
243
243
for ( const item of testData ) {
@@ -247,6 +247,7 @@ describe(`Query Index Optimization`, () => {
247
247
} )
248
248
}
249
249
commit ( )
250
+ markReady ( )
250
251
251
252
// Listen for mutations and sync them back (only register once)
252
253
if ( ! emitter . all . has ( `sync` ) ) {
@@ -534,7 +535,7 @@ describe(`Query Index Optimization`, () => {
534
535
getKey : ( item ) => item . id ,
535
536
startSync : true ,
536
537
sync : {
537
- sync : ( { begin, write, commit } ) => {
538
+ sync : ( { begin, write, commit, markReady } ) => {
538
539
begin ( )
539
540
write ( {
540
541
type : `insert` ,
@@ -547,6 +548,7 @@ describe(`Query Index Optimization`, () => {
547
548
} ,
548
549
} )
549
550
commit ( )
551
+ markReady ( )
550
552
} ,
551
553
} ,
552
554
} )
@@ -622,7 +624,7 @@ describe(`Query Index Optimization`, () => {
622
624
getKey : ( item ) => item . id ,
623
625
startSync : true ,
624
626
sync : {
625
- sync : ( { begin, write, commit } ) => {
627
+ sync : ( { begin, write, commit, markReady } ) => {
626
628
begin ( )
627
629
write ( {
628
630
type : `insert` ,
@@ -645,6 +647,7 @@ describe(`Query Index Optimization`, () => {
645
647
} ,
646
648
} )
647
649
commit ( )
650
+ markReady ( )
648
651
} ,
649
652
} ,
650
653
} )
0 commit comments