Pagination

createInfiniteQuery

Cursor/offset pagination that accumulates pages. start loads the first page (resetting), fetchNext appends the next — driven by getNextPageParam.

import { createInfiniteQuery } from 'effector-refetch';

const feed = createInfiniteQuery({
  effect: fetchPageFx, // Effect<{ params, pageParam }, Page>
  initialPageParam: 0,
  getNextPageParam: ({ lastPage }) => lastPage.nextCursor ?? null, // null/undefined = done
});

feed.start({ tag: 'cats' });
feed.fetchNext(); // appends; no-op when $hasNextPage is false or already loading

Exposes $pages (= $data), $pageParams, $hasNextPage, $status, $pending, $error, finished.{done,fail}, and useUnit(feed) support.

getNextPageParam receives { lastPage, allPages, lastPageParam, allPageParams } and returns the next page param, or null/undefined when there are no more pages.

Bidirectional + windowing

Add getPreviousPageParam to enable fetchPrevious (prepends), and maxPages to cap the window (drops from the opposite end):

const feed = createInfiniteQuery({
  effect: fetchPageFx,
  initialPageParam: 10, // start in the middle
  getNextPageParam: ({ lastPage }) => lastPage.next ?? null,
  getPreviousPageParam: ({ firstPage }) => firstPage.prev ?? null,
  maxPages: 3,
});

feed.fetchPrevious(); // prepend; gated by $hasPreviousPage

Exposes $hasPreviousPage alongside $hasNextPage.

combineQueries — parallel queries

Aggregate several independent queries into combined stores (the effector-flavored useQueries):

import { combineQueries } from 'effector-refetch';

const { $data, $pending, $isSuccess, $isError, $statuses, $errors } = combineQueries([userQuery, postsQuery]);
// $data: [User | null, Post[] | null]   $pending: any in flight   $isSuccess: all done

Start the queries as usual; combineQueries just reads their combined state.

TIP

The page effect is a plain Effect<{ params, pageParam }, Page> — use a regular createEffect/handler, not an abort-aware createRequestFx effect (which has a different { params, signal } calling convention).

Built on createQuery, so the page fetch inherits concurrency and cancellation.