@@ -365,27 +365,33 @@ describe('queriesObserver', () => {
365
365
const results : Array < Array < QueryObserverResult > > = [ ]
366
366
results . push ( observer . getCurrentResult ( ) )
367
367
368
- const unsubscribe = observer . subscribe ( ( result ) => {
368
+ const onUpdate = vi . fn ( ( result : Array < QueryObserverResult > ) => {
369
369
results . push ( result )
370
370
} )
371
+ const unsubscribe = observer . subscribe ( onUpdate )
372
+ const baseline = results . length
371
373
372
374
observer . setQueries ( [
373
- { queryKey : key1 , queryFn : queryFn1 , staleTime : Infinity } ,
374
- { queryKey : key2 , queryFn : queryFn2 , staleTime : Infinity } ,
375
+ {
376
+ queryKey : key1 ,
377
+ queryFn : queryFn1 ,
378
+ select : ( d : any ) => d + 100 ,
379
+ } ,
380
+ {
381
+ queryKey : key2 ,
382
+ queryFn : queryFn2 ,
383
+ select : ( d : any ) => d + 100 ,
384
+ } ,
375
385
] )
376
386
377
387
await vi . advanceTimersByTimeAsync ( 0 )
378
388
379
389
unsubscribe ( )
380
390
381
- expect ( results . length ) . toBeGreaterThanOrEqual ( 2 )
382
- expect ( results [ 0 ] ) . toMatchObject ( [
383
- { status : 'success' , data : 1 } ,
384
- { status : 'success' , data : 2 } ,
385
- ] )
391
+ expect ( results . length ) . toBeGreaterThan ( baseline )
386
392
expect ( results [ results . length - 1 ] ) . toMatchObject ( [
387
- { status : 'success' , data : 1 } ,
388
- { status : 'success' , data : 2 } ,
393
+ { status : 'success' , data : 101 } ,
394
+ { status : 'success' , data : 102 } ,
389
395
] )
390
396
} )
391
397
} )
0 commit comments