Операторы

Каждая inline-опция createQuery — это сахар над standalone-оператором. Импортируй и применяй к любому query/mutation (в т.ч. созданному в другом месте). Композируемы и tree-shakeable.

import { concurrency, retry, cache, timeout, keepFresh, applyBarrier } from 'effector-refetch';

concurrency

Поведение пересекающихся прогонов: TAKE_LATEST (по умолчанию), TAKE_FIRST, TAKE_EVERY.

concurrency(searchQuery, { strategy: 'TAKE_LATEST' }); // новый прогон отменяет предыдущий

retry

retry(query, 3) или конфиг. Каждая попытка — реальный вызов эффекта; filter решает, какие сбои ретраить, suppressIntermediateErrors держит $error чистым до финальной попытки.

import { exponentialDelay } from 'effector-refetch';

retry(userQuery, {
  times: 3,
  delay: exponentialDelay(200),
  filter: ({ error }) => (error as RequestError).status !== 404, // не ретраить 404
});

cache

cache(query) (in-memory) или конфиг (adapter / staleAfter / key / swr / dedupe / purge).

cache(productsQuery, { staleAfter: 30_000, swr: true, purge: loggedOut });

timeout

Дедлайн одной попытки (мс): прерывает запрос в полёте и роняет прогон (ретраябельно), если превышен. 0 — выкл. Не путать с refetchInterval (частота поллинга).

timeout(reportQuery, 5000); // сдаёмся на одной попытке через 5с

keepFresh

Рефетчит запрос его последними параметрами при изменении стора-source или при срабатывании @@trigger — свежесть по зависимости (фильтры, локаль, пользователь, успешная мутация, ping по websocket). No-op до первого запуска и пока disabled.

keepFresh(productsQuery, { source: $filters }); // или source: [$filters, $locale]

// triggers: что угодно с протоколом @@trigger или обычный effector Event
keepFresh(productsQuery, { triggers: [createProductMutation, tabFocused] });

triggers принимает наши же query/mutation (они реализуют @@trigger — fired = finished.done), триггеры web-API из withease, совместимые с farfetched триггеры или сырой Event. У каждого триггера setup дёргается один раз при подключении и остаётся активным на всё время жизни приложения.

Протокол @@trigger

Каждый query и mutation является @@trigger: query['@@trigger']() возвращает { fired, setup, teardown }, где fired — это finished.done. Поэтому запрос можно отдавать в keepFresh({ triggers }) самого farfetched (и наоборот), либо в любого потребителя протокола:

import { keepFresh } from '@farfetched/core';

keepFresh(someFarfetchedQuery, { triggers: [ourQuery] }); // ourQuery успешен → farfetched рефетчит

isTrigger(x) сужает тип к протоколу. Наши юниты — always-on триггеры: setup/teardown есть для совместимости с протоколом, но не гейтят срабатывание (запрос живёт своим scoped-жизненным циклом).

applyBarrier

Навешивает на готовый query/mutation barrier (например 401 → обновить токен → продолжить). null — отвязать.

const auth = createBarrier({ perform: refreshTokenFx });
applyBarrier(userQuery, auth);

Повторное применение оператора

Два чётко определённых поведения, по типу оператора:

• Last-wins — concurrency / retry / cache / timeout / applyBarrier это engine-сеттеры: второй вызов заменяет первый. retry(q, 1); retry(q, 3) ⇒ 3 ретрая; applyBarrier(q, null) отвязывает.
• Аддитивно — keepFresh / invalidate / update добавляют проводку на каждый вызов: два зарегистрированных keepFresh-источника — рефетч на изменение любого из них.

Это намеренно и покрыто тестом (test/multi-operators.test.ts) — last-wins для одно-значных конфиг-ручек, аддитивно для тех, что регистрируют реакции.

---

Всё это эквивалентно соответствующей опции createQuery({ … }) — выбирай, что читается лучше. Рабочий пример: examples/operators.ts.