Skip to main content Link Search Menu Expand Document (external link)
fp-ts-ix

Merge overview

ReaderAsyncIterable/Merge

Added in v0.1.0

Table of contents

Monad

chain

Signature

export declare const chain: <A, R, B>(
  f: (a: A) => RAI.ReaderAsyncIterable<R, B>
) => (ma: RAI.ReaderAsyncIterable<R, A>) => RAI.ReaderAsyncIterable<R, B>

Added in v0.1.0

combinators

chainAsyncIterableK

Signature

export declare const chainAsyncIterableK: <A, B>(
  f: (a: A) => AsyncIterable<B>
) => <E>(first: RAI.ReaderAsyncIterable<E, A>) => RAI.ReaderAsyncIterable<E, B>

Added in v0.1.0

chainFirst

Composes computations in sequence, using the return value of one computation to determine the next computation and keeping only the result of the first.

Derivable from Chain.

Signature

export declare const chainFirst: <A, E, B>(
  f: (a: A) => RAI.ReaderAsyncIterable<E, B>
) => (first: RAI.ReaderAsyncIterable<E, A>) => RAI.ReaderAsyncIterable<E, A>

Added in v0.1.0

chainFirstAsyncIterableK

Signature

export declare const chainFirstAsyncIterableK: <A, B>(
  f: (a: A) => AsyncIterable<B>
) => <E>(first: RAI.ReaderAsyncIterable<E, A>) => RAI.ReaderAsyncIterable<E, A>

Added in v0.1.0

chainFirstIOK

Signature

export declare const chainFirstIOK: <A, B>(
  f: (a: A) => IO<B>
) => <E>(first: RAI.ReaderAsyncIterable<E, A>) => RAI.ReaderAsyncIterable<E, A>

Added in v0.1.0

chainFirstReaderK

Signature

export declare const chainFirstReaderK: <A, R, B>(
  f: (a: A) => Reader<R, B>
) => (ma: RAI.ReaderAsyncIterable<R, A>) => RAI.ReaderAsyncIterable<R, A>

Added in v0.1.0

chainFirstReaderKW

Less strict version of chainFirstReaderK.

Signature

export declare const chainFirstReaderKW: <A, R1, B>(
  f: (a: A) => Reader<R1, B>
) => <R2>(ma: RAI.ReaderAsyncIterable<R2, A>) => RAI.ReaderAsyncIterable<R1 & R2, A>

Added in v0.1.0

chainFirstTaskK

Signature

export declare const chainFirstTaskK: <A, B>(
  f: (a: A) => Task<B>
) => <E>(first: RAI.ReaderAsyncIterable<E, A>) => RAI.ReaderAsyncIterable<E, A>

Added in v0.1.0

chainFirstW

Less strict version of chainFirst.

Derivable from Chain.

Signature

export declare const chainFirstW: <R2, A, B>(
  f: (a: A) => RAI.ReaderAsyncIterable<R2, B>
) => <R1>(ma: RAI.ReaderAsyncIterable<R1, A>) => RAI.ReaderAsyncIterable<R1 & R2, A>

Added in v0.1.0

chainIOK

Signature

export declare const chainIOK: <A, B>(
  f: (a: A) => IO<B>
) => <E>(first: RAI.ReaderAsyncIterable<E, A>) => RAI.ReaderAsyncIterable<E, B>

Added in v0.1.0

chainReaderK

Signature

export declare const chainReaderK: <A, R, B>(
  f: (a: A) => Reader<R, B>
) => (ma: RAI.ReaderAsyncIterable<R, A>) => RAI.ReaderAsyncIterable<R, B>

Added in v0.1.0

chainReaderKW

Less strict version of chainReaderK.

Signature

export declare const chainReaderKW: <A, R1, B>(
  f: (a: A) => Reader<R1, B>
) => <R2>(ma: RAI.ReaderAsyncIterable<R2, A>) => RAI.ReaderAsyncIterable<R1 & R2, B>

Added in v0.1.0

chainTaskK

Signature

export declare const chainTaskK: <A, B>(
  f: (a: A) => Task<B>
) => <E>(first: RAI.ReaderAsyncIterable<E, A>) => RAI.ReaderAsyncIterable<E, B>

Added in v0.1.0

chainWithIndex

Composes computations in sequence, using the return value of one computation to determine the next computation.

Signature

export declare const chainWithIndex: <R, A, B>(
  f: (i: number, a: A) => RAI.ReaderAsyncIterable<R, B>
) => (ma: RAI.ReaderAsyncIterable<R, A>) => RAI.ReaderAsyncIterable<R, B>

Added in v0.1.0

chainWithIndexW

Less strict version of chainWithIndex.

Signature

export declare const chainWithIndexW: <R2, A, B>(
  f: (i: number, a: A) => RAI.ReaderAsyncIterable<R2, B>
) => <R1>(ma: RAI.ReaderAsyncIterable<R1, A>) => RAI.ReaderAsyncIterable<R1 & R2, B>

Added in v0.1.0

flatten

Derivable from Chain.

Signature

export declare const flatten: <R, A>(
  mma: RAI.ReaderAsyncIterable<R, RAI.ReaderAsyncIterable<R, A>>
) => RAI.ReaderAsyncIterable<R, A>

Added in v0.1.0

flattenW

Less strict version of flatten.

Signature

export declare const flattenW: <R1, R2, A>(
  mma: RAI.ReaderAsyncIterable<R1, RAI.ReaderAsyncIterable<R2, A>>
) => RAI.ReaderAsyncIterable<R1 & R2, A>

Added in v0.1.0

instances

Chain

Signature

export declare const Chain: Chain2<'ReaderAsyncIterable'>

Added in v0.1.0

ChainWithIndex

Signature

export declare const ChainWithIndex: ChainWithIndex2<'ReaderAsyncIterable', number>

Added in v0.1.0

Monad

Signature

export declare const Monad: Monad2<'ReaderAsyncIterable'>

Added in v0.1.0

MonadAsyncIterable

Signature

export declare const MonadAsyncIterable: MonadAsyncIterable2<'ReaderAsyncIterable'>

Added in v0.1.0

MonadIO

Signature

export declare const MonadIO: MonadIO2<'ReaderAsyncIterable'>

Added in v0.1.0

MonadTask

Signature

export declare const MonadTask: MonadTask2<'ReaderAsyncIterable'>

Added in v0.1.0

getSemigroup

Get a Semigroup based on the concatenation of AsyncIterables. See also getMonoid.

Signature

export declare const getSemigroup: <R = unknown, A = never>() => Semigroup<RAI.ReaderAsyncIterable<R, A>>

Added in v0.1.0

utils

bind

Signature

export declare const bind: <N, A, E, B>(
  name: Exclude<N, keyof A>,
  f: (a: A) => RAI.ReaderAsyncIterable<E, B>
) => (
  ma: RAI.ReaderAsyncIterable<E, A>
) => RAI.ReaderAsyncIterable<E, { readonly [K in N | keyof A]: K extends keyof A ? A[K] : B }>

Added in v0.1.0

bindW

Signature

export declare const bindW: <N extends string, A, R2, B>(
  name: Exclude<N, keyof A>,
  f: (a: A) => RAI.ReaderAsyncIterable<R2, B>
) => <R1>(
  fa: RAI.ReaderAsyncIterable<R1, A>
) => RAI.ReaderAsyncIterable<R1 & R2, { readonly [K in N | keyof A]: K extends keyof A ? A[K] : B }>

Added in v0.1.0

getMonoid

Signature

export declare const getMonoid: <R = unknown, A = never>() => Monoid<RAI.ReaderAsyncIterable<R, A>>

Added in v0.1.0