Function refReader

packages/effect/test/Channel/reading.test.ts:44–61

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

}

export const refReader = <A>(
  ref: Ref.Ref<Array<A>>
): Channel.Channel<A, unknown, never, unknown, void, unknown> => {
  return pipe(
    Channel.fromEffect(
      Ref.modify(ref, (array) => {
        if (Array.isEmptyReadonlyArray(array)) {
          return [Option.none(), Array.empty<A>()] as const
        }
        return [Option.some(array[0]!), array.slice(1)] as const
      })
    ),
    Channel.flatMap(Option.match({
      onNone: () => Channel.void,
      onSome: (i) => Channel.flatMap(Channel.write(i), () => refReader(ref))
    }))
  )
}

describe("Channel", () => {
  it.effect("simple reads", () =>