Function f

packages/effect/test/Stream/taking.test.ts:66–66

(n: number)

    Effect.gen(function*() {
      const stream = Stream.range(1, 5)
      const f = (n: number) => n % 3 === 0
      const { result1, result2 } = yield* (Effect.all({
        result1: pipe(stream, Stream.takeUntil(f), Stream.runCollect),
        result2: pipe(