Function refWriter

packages/effect/test/Channel/reading.test.ts:30–42

(
  ref: Ref.Ref<ReadonlyArray<A>>
)

}

export const refWriter = <A>(
  ref: Ref.Ref<ReadonlyArray<A>>
): Channel.Channel<never, A, never, unknown, void, unknown> => {
  return Channel.readWith({
    onInput: (a: A) =>
      Channel.flatMap(
        Channel.fromEffect(Effect.asVoid(Ref.update(ref, Array.prepend(a)))),
        () => refWriter(ref)
      ),
    onFailure: () => Channel.void,
    onDone: () => Channel.void
  })
}

export const refReader = <A>(
  ref: Ref.Ref<Array<A>>