Function program

packages/effect/test/Sink/collecting.test.ts:221–233

(chunkSize: number)

  it.effect("collectAllWhileWith - example 1", () =>
    Effect.gen(function*() {
      const program = (chunkSize: number) =>
        pipe(
          Stream.fromChunk(Chunk.range(1, 10)),
          Stream.rechunk(chunkSize),
          Stream.run(pipe(
            Sink.sum,
            Sink.collectAllWhileWith({
              initial: -1,
              while: (n) => n === n,
              body: (acc, curr) => acc + curr
            })
          ))
        )
      const result1 = yield* (program(1))
      const result2 = yield* (program(3))
      const result3 = yield* (program(20))