/** * @typed/fp/ReaderTask is an extension of fp-ts/ReaderTask with additional * type-class instances. * @since 0.9.2 */ import { ChainRec2 } from 'fp-ts/ChainRec' import * as E from 'fp-ts/Either' import { pipe } from 'fp-ts/function' import * as RT from 'fp-ts/ReaderTask' import { MonadRec2 } from './MonadRec' import { Provide2, ProvideAll2, ProvideSome2, UseAll2, UseSome2 } from './Provide' /** * @since 0.9.2 * @category Combinator */ export const chainRec = (f: (value: A) => RT.ReaderTask>) => (value: A): RT.ReaderTask => pipe(value, f, RT.chain(E.match(chainRec(f), RT.of))) // Recursion is okay because promise is always async /** * @since 0.9.2 * @category Instance */ export const ChainRec: ChainRec2 = { chainRec, } /** * @since 0.9.2 * @category Instance */ export const MonadRec: MonadRec2 = { ...RT.Monad, chainRec, } /** * @since 0.9.2 * @category Combinator */ export const useSome = (provided: R1) => (readerTask: RT.ReaderTask): RT.ReaderTask => (r) => readerTask({ ...r, ...provided }) /** * @since 0.9.2 * @category Combinator */ export const provideSome = (provided: R1) => (readerTask: RT.ReaderTask): RT.ReaderTask => (r) => readerTask({ ...provided, ...r }) /** * @since 0.9.2 * @category Combinator */ export const useAll = (provided: R1) => (readerTask: RT.ReaderTask): RT.ReaderTask => () => readerTask(provided) /** * @since 0.9.2 * @category Combinator */ export const provideAll = (provided: R1) => (readerTask: RT.ReaderTask): RT.ReaderTask => (r) => readerTask({ ...provided, ...(r as {}) }) /** * @since 0.9.2 * @category Instance */ export const UseSome: UseSome2 = { useSome, } /** * @since 0.9.2 * @category Instance */ export const UseAll: UseAll2 = { useAll, } /** * @since 0.9.2 * @category Instance */ export const ProvideSome: ProvideSome2 = { provideSome, } /** * @since 0.9.2 * @category Instance */ export const ProvideAll: ProvideAll2 = { provideAll, } /** * @since 0.9.2 * @category Instance */ export const Provide: Provide2 = { useSome, useAll, provideSome, provideAll, } export * from 'fp-ts/ReaderTask'