File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -66,6 +66,7 @@ describe('Sync streams', () => {
6666 streams : [ stream ( 'stream' , false ) ]
6767 } )
6868 ) ;
69+ console . log ( 'waiting for status update after sending checkpoint line' ) ;
6970 let status = await statusPromise ;
7071 for ( const subscription of [ a , b ] ) {
7172 expect ( status . forStream ( subscription ) . subscription . active ) . toBeTruthy ( ) ;
@@ -75,12 +76,15 @@ describe('Sync streams', () => {
7576
7677 statusPromise = nextStatus ( database ) ;
7778 syncService . pushLine ( { partial_checkpoint_complete : { last_op_id : '0' , priority : 1 } } ) ;
79+ console . log ( 'waiting for status update after sending partial checkpoint complete' ) ;
7880 status = await statusPromise ;
7981 expect ( status . forStream ( a ) . subscription . lastSyncedAt ) . toBeNull ( ) ;
8082 expect ( status . forStream ( b ) . subscription . lastSyncedAt ) . not . toBeNull ( ) ;
83+ console . log ( 'waiting for b.waitForFirstSync()' ) ;
8184 await b . waitForFirstSync ( ) ;
8285
8386 syncService . pushLine ( { checkpoint_complete : { last_op_id : '0' } } ) ;
87+ console . log ( 'waiting for a.waitForFirstSync() after sending checkpoint_complete line' ) ;
8488 await a . waitForFirstSync ( ) ;
8589 } ) ;
8690
You can’t perform that action at this time.
0 commit comments