fp-ts-ix v0.1.1

fp-ts bindings for IxJS asynciterable

Implemented instances

• Monad
• FunctorWithIndex
• Filterable

Example

import { from } from 'ix/asynciterable'
import { map } from 'fp-ts-ix/AsyncIterable'
import { pipe } from 'fp-ts/function'

const fa = pipe(
  from([1, 2, 3]),
  map(a => a * 2*),
)
// will emit 2, 4, 6

Chain

Different Chain instances are provided in order to support flatMap (merge), concatMap and switchMap:

import { from } from 'ix/asynciterable'
import { map, chain } from 'fp-ts-ix/AsyncIterable'
import { pipe } from 'fp-ts/function'
import * as AIc from 'fp-ts-ix/AsyncIterable/Concat'
import * as AIm from 'fp-ts-ix/AsyncIterable/Merge'
import * as AIs from 'fp-ts-ix/AsyncIterable/Switch'

const fa = pipe(
  from([1, 2]),
  chain(AIc.Chain)(a => from([3, 4])),
)
// will emit 1, 2, 3, 4

const fb = pipe(
  from([1, 2]),
  chain(AIm.Chain)(a => from([3, 4])),
)
// will emit 1, 3, 4, 4 (parallel processing)

const fc = pipe(
  from([1, 2]),
  chain(AIs.Chain)(a => from([3, 4])),
)
// will emit 3, 4 (switchMap)


//
// Or you can use already provided pipable functions from Chain modules
//
const fa2 = pipe(
  from([1, 2]),
  AIc.chain(a => from([3, 4])),
)
// will emit 1, 2, 3, 4

const fb2 = pipe(
  from([1, 2]),
  AIm.chain(a => from([3, 4])),
)
// will emit 1, 3, 4, 4 (parallel processing)

const fb2 = pipe(
  from([1, 2]),
  AIs.chain(a => from([3, 4])),
)
// will emit 3, 4 (switchMap)

TypeScript compatibility

The stable version is tested against TypeScript 4.8

ixjs compatibility

Documentation

• API Reference