Function mapper

packages/effect/test/Channel/reading.test.ts:16–28

(
  f: (a: A) => B
)

import * as Ref from "effect/Ref"

export const mapper = <A, B>(
  f: (a: A) => B
): Channel.Channel<B, A, never, unknown, void, unknown> => {
  return Channel.readWith({
    onInput: (a: A) =>
      Channel.flatMap(
        Channel.write(f(a)),
        () => mapper(f)
      ),
    onFailure: () => Channel.void,
    onDone: () => Channel.void
  })
}

export const refWriter = <A>(
  ref: Ref.Ref<ReadonlyArray<A>>