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

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)