Function withPermitsScoped

packages/effect/test/Stream/sequencing.test.ts:16–20

(permits: number)

import * as Take from "effect/Take"

const withPermitsScoped = (permits: number) => (semaphore: Effect.Semaphore) =>
  Effect.acquireRelease(
    semaphore.take(permits),
    (n) => semaphore.release(n)
  )

describe("Stream", () => {
  it.effect("branchAfter - switches streams", () =>