@@ -549,9 +549,7 @@ export class Query<
549549 this . features . autoRemovePreviousQuery &&
550550 options . queryHash !== nextQueryHash
551551 ) {
552- this . queryClient . removeQueries ( {
553- predicate : ( query ) => query . queryHash === options . queryHash ,
554- } ) ;
552+ this . remove ( { safe : true } ) ;
555553 }
556554
557555 options . queryHash = nextQueryHash ;
@@ -616,7 +614,8 @@ export class Query<
616614 this . cumulativeQueryKeyHashesSet . has ( query . options . queryHash ! ) &&
617615 ( query . observers . length === 0 ||
618616 ( query . observers . length === 1 &&
619- query . observers [ 0 ] === this . queryObserver ) )
617+ query . observers [ 0 ] === this . queryObserver ) ) &&
618+ ( ! params ?. predicate || params . predicate ( query ) )
620619 ) ;
621620 } ,
622621 ...params ,
@@ -641,7 +640,8 @@ export class Query<
641640 this . cumulativeQueryKeyHashesSet . has ( query . options . queryHash ! ) &&
642641 ( query . observers . length === 0 ||
643642 ( query . observers . length === 1 &&
644- query . observers [ 0 ] === this . queryObserver ) )
643+ query . observers [ 0 ] === this . queryObserver ) ) &&
644+ ( ! params ?. predicate || params . predicate ( query ) )
645645 ) ;
646646 } ,
647647 ...params ,
@@ -655,7 +655,8 @@ export class Query<
655655 query . queryHash === this . options . queryHash &&
656656 ( query . observers . length === 0 ||
657657 ( query . observers . length === 1 &&
658- query . observers [ 0 ] === this . queryObserver ) ) ,
658+ query . observers [ 0 ] === this . queryObserver ) ) &&
659+ ( ! params ?. predicate || params . predicate ( query ) ) ,
659660 } ) ;
660661 }
661662
0 commit comments