/
githubmirror
/
trpc
Обзор
Документация
Войти
/
githubmirror
/
trpc
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
packages/client/src/links/splitLink.ts
30 строк
1 KB
Alex / KATT
fix(server): delete the `@trpc/core`-package (#5355)
19 янв 2024, 17:08
Не верифицирован
19 янв 2024, 17:08
c9f72c9
Код
Авторство
О чём код?
import { observable } from '@trpc/server/observable'; import type { AnyRouter } from '@trpc/server/unstable-core-do-not-import'; import { createChain } from './internals/createChain'; import type { Operation, TRPCLink } from './types'; function asArray<TType>(value: TType | TType[]) { return Array.isArray(value) ? value : [value]; } export function splitLink<TRouter extends AnyRouter = AnyRouter>(opts: { condition: (op: Operation) => boolean; /** * The link to execute next if the test function returns `true`. */ true: TRPCLink<TRouter> | TRPCLink<TRouter>[]; /** * The link to execute next if the test function returns `false`. */ false: TRPCLink<TRouter> | TRPCLink<TRouter>[]; }): TRPCLink<TRouter> { return (runtime) => { const yes = asArray(opts.true).map((link) => link(runtime)); const no = asArray(opts.false).map((link) => link(runtime)); return (props) => { return observable((observer) => { const links = opts.condition(props.op) ? yes : no; return createChain({ op: props.op, links }).subscribe(observer); }); }; }; }