fix(useInfiniteSubscription): fix unsubscribing when previous/next page has been fetched

Author: Katarina Anton

src/subscription-storage.ts

@@ -53,10 +53,6 @@ export function cleanupSubscription<
 
  if (!subscription) return;
 
- subscription.forEach((subscription) => {
- subscription.unsubscribe();
- });
-
  if (pageParam === undefined) {
  subscription.forEach((subscription) => {
  subscription.unsubscribe();

src/use-infinite-subscription.ts

@@ -78,7 +78,7 @@ export interface UseInfiniteSubscriptionOptions<
  onData?: (data: InfiniteData<TData>) => void;
 }
 
-export type UseSubscriptionResult<
+export type UseInfiniteSubscriptionResult<
  TData = unknown,
  TError = unknown
 > = UseInfiniteQueryResult<TData, TError>;
@@ -160,14 +160,14 @@ export function useInfiniteSubscription<
  TData,
  TSubscriptionKey
  > = {}
-): UseSubscriptionResult<TData, TError> {
+): UseInfiniteSubscriptionResult<TData, TError> {
  const { queryFn, clearErrors } = useObservableQueryFn(
  subscriptionFn,
  (data, previousData, pageParam): InfiniteData<TSubscriptionFnData> => {
  if (!isInfiniteData(previousData)) {
  return {
  pages: [data],
- pageParams: [undefined],
+ pageParams: [pageParam],
  };
  }
  const pageIndex = previousData.pageParams.findIndex(