Function makeInner

packages/effect/test/Stream.test.ts:1348–1353

()

        )
      )
      const makeInner = () => {
        started.openUnsafe()
        return (inner === "never" ? Stream.never : Stream.fromEffect(Effect.sleep(Duration.hours(1)))).pipe(
          Stream.ensuring(Ref.update(finalized, (n) => n + 1))
        )
      }
      const stream = combinator === "flatMap"
        ? Stream.flatMap(outer, makeInner, { concurrency: 2 })
        : Stream.switchMap(outer, makeInner)