Пагинация

createInfiniteQuery

Курсорная/offset-пагинация с накоплением страниц. start грузит первую страницу (со сбросом), fetchNext докидывает следующую — по getNextPageParam.

import { createInfiniteQuery } from 'effector-refetch';

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

feed.start({ tag: 'cats' });
feed.fetchNext(); // докидывает; no-op, если $hasNextPage = false или уже грузится
feed.refetchAll(); // перезапрашивает ВСЕ накопленные страницы (те же pageParams), сохраняя окно

Предоставляет $pages (= $data), $pageParams, $hasNextPage, $hasPreviousPage, $status, $pending, $error, finished.{done,fail} и поддержку useUnit(feed). Флаги загрузки: $isInitialLoading (страниц ещё нет — скелетон), $isFetchingNextPage / $isFetchingPreviousPage (какой конец грузится), $isRefetching (refetchAll перезагружает окно).

getNextPageParam получает { lastPage, allPages, lastPageParam, allPageParams } и возвращает параметр следующей страницы либо null/undefined, когда страниц больше нет.

Двунаправленность + окно

Добавьте getPreviousPageParam, чтобы включить fetchPrevious (вставка в начало), и maxPages, чтобы ограничить окно (сбрасывает с противоположного конца):

const feed = createInfiniteQuery({
  effect: fetchPageFx,
  initialPageParam: 10, // старт с середины
  getNextPageParam: ({ lastPage }) => lastPage.next ?? null,
  getPreviousPageParam: ({ firstPage }) => firstPage.prev ?? null,
  maxPages: 3,
});

feed.fetchPrevious(); // prepend; гейт по $hasPreviousPage

Появляется $hasPreviousPage рядом с $hasNextPage.

combineQueries — параллельные запросы

Агрегирует несколько независимых запросов в общие сторы (эффектор-овский useQueries):

import { combineQueries } from 'effector-refetch';

const { $data, $pending, $isSuccess, $isError, $statuses, $errors } = combineQueries([userQuery, postsQuery]);
// $data: [User | null, Post[] | null]   $pending: любой в полёте   $isSuccess: все done

Запускайте запросы как обычно; combineQueries лишь читает их общее состояние.

TIP

Эффект страницы — Effect<{ params, pageParam }, Page>: обычный createEffect/handler или abort-aware createRequestFx-эффект (AbortSignal доходит до него через синхронный side-канал, так что загрузка страниц остаётся отменяемой).

Построено на createQuery, поэтому загрузка страницы наследует concurrency и отмену.

retry и timeout

Загрузка страницы принимает те же опции retry и timeout, что и createQuery — они действуют для start, fetchNext, fetchPrevious и для каждой страницы refetchAll:

const feed = createInfiniteQuery({
  effect: fetchPageFx,
  initialPageParam: 0,
  getNextPageParam: ({ lastPage }) => lastPage.next ?? null,
  retry: { times: 2, delay: exponentialDelay(300) },
  timeout: 5_000, // на попытку
});

refetchAll перезагружает окно напрямую через эффект (мимо page-запроса), поэтому timeout до него не доходит — но конфиг retry применяется к каждой странице внутри цикла перезагрузки, а повторная попытка ждёт barrier наравне с остальными.

Барьер

Передайте barrier (из createBarrier), чтобы гейтить все запросы — start, fetchNext, fetchPrevious и refetchAll ждут, пока барьер залочен (например, во время обновления токена). refetchAll перепроверяет барьер перед каждой страницей, поэтому начавшийся в середине окна refresh придержит оставшиеся страницы:

import { createBarrier, createInfiniteQuery } from 'effector-refetch';

const authBarrier = createBarrier({ perform: refreshTokenFx });

const feed = createInfiniteQuery({
  effect: fetchPageFx,
  initialPageParam: 0,
  getNextPageParam: ({ lastPage }) => lastPage.next ?? null,
  barrier: authBarrier,
  // повторная попытка страницы тоже ждёт барьер — именно она переигрывает упавшую на 401
  retry: { times: 1, filter: ({ error }) => error.status === 401 },
});

Полный сценарий 401 — в рецепте auth & barrier.