Function stream

packages/effect/test/Stream/scoping.test.ts:156–165

(deferred: Deferred.Deferred<void, never>, ref: Ref.Ref<ReadonlyArray<string>>)

    const awaiter = Deferred.unsafeMake<void>(FiberId.none)
    const program = Effect.gen(function*() {
      const stream = (deferred: Deferred.Deferred<void, never>, ref: Ref.Ref<ReadonlyArray<string>>) =>
        Effect.acquireRelease(
          Ref.update(ref, (array) => [...array, "acquire outer"]),
          () => Ref.update(ref, (array) => [...array, "release outer"])
        ).pipe(
          Effect.zipRight(Deferred.succeed(deferred, void 0)),
          Effect.zipRight(Deferred.await(awaiter)),
          Effect.zipRight(Effect.succeed(Stream.make(1, 2, 3))),
          Stream.unwrapScoped
        )
      const ref = yield* Ref.make<ReadonlyArray<string>>([])
      const deferred = yield* Deferred.make<void>()
      const fiber = yield* stream(deferred, ref).pipe(Stream.runDrain, Effect.fork)