@@ -1214,7 +1214,7 @@ describe('isSyncEnabled', () => {
12141214 const obs$ = observable < Record < string , { id : string ; test : string } > > ( ) ;
12151215 const ev$ = event ( ) ;
12161216 let gets = 0 ;
1217- let sets = 0 ;
1217+ const sets$ = observable ( 0 ) ;
12181218 const state$ = syncObservable ( obs$ , {
12191219 get : ( ) => {
12201220 gets ++ ;
@@ -1227,7 +1227,7 @@ describe('isSyncEnabled', () => {
12271227 } ;
12281228 } ,
12291229 set : ( ) => {
1230- sets ++ ;
1230+ sets$ . set ( ( v ) => v + 1 ) ;
12311231 } ,
12321232 } as SyncedOptions ) ;
12331233
@@ -1238,20 +1238,20 @@ describe('isSyncEnabled', () => {
12381238 } ,
12391239 } ) ;
12401240 expect ( gets ) . toEqual ( 1 ) ;
1241- expect ( sets ) . toEqual ( 0 ) ;
1241+ expect ( sets$ . get ( ) ) . toEqual ( 0 ) ;
12421242
12431243 obs$ . id1 . test . set ( 'hello' ) ;
12441244
1245- await promiseTimeout ( 0 ) ;
1245+ await when ( ( ) => sets$ . get ( ) === 1 ) ;
12461246
12471247 expect ( gets ) . toEqual ( 1 ) ;
1248- expect ( sets ) . toEqual ( 1 ) ;
1248+ expect ( sets$ . get ( ) ) . toEqual ( 1 ) ;
12491249
12501250 ev$ . fire ( ) ;
12511251 obs$ . get ( ) ;
12521252
12531253 expect ( gets ) . toEqual ( 2 ) ;
1254- expect ( sets ) . toEqual ( 1 ) ;
1254+ expect ( sets$ . get ( ) ) . toEqual ( 1 ) ;
12551255
12561256 state$ . isSyncEnabled . set ( false ) ;
12571257
@@ -1260,12 +1260,12 @@ describe('isSyncEnabled', () => {
12601260 await promiseTimeout ( 0 ) ;
12611261
12621262 expect ( gets ) . toEqual ( 2 ) ;
1263- expect ( sets ) . toEqual ( 1 ) ;
1263+ expect ( sets$ . get ( ) ) . toEqual ( 1 ) ;
12641264
12651265 ev$ . fire ( ) ;
12661266
12671267 expect ( gets ) . toEqual ( 2 ) ;
1268- expect ( sets ) . toEqual ( 1 ) ;
1268+ expect ( sets$ . get ( ) ) . toEqual ( 1 ) ;
12691269 } ) ;
12701270} ) ;
12711271describe ( 'synced is observer' , ( ) => {
0 commit comments