Function close

packages/effect/src/Stream.ts:11111–11122

(exit: Exit.Exit<unknown, unknown>)

      let currentFiber: Fiber.Fiber<Arr.NonEmptyReadonlyArray<A>, E | Cause.Done<void>> | undefined
      let closePromise: Promise<IteratorResult<A>> | undefined
      const close = (exit: Exit.Exit<unknown, unknown>): Promise<IteratorResult<A>> => {
        if (closePromise) return closePromise
        const fiber = currentFiber
        closePromise = runPromise(Effect.as(
          Effect.andThen(
            fiber ? Fiber.interrupt(fiber) : Effect.void,
            Scope.close(scope, exit)
          ),
          { done: true, value: undefined }
        ))
        return closePromise
      }
      const closeAndReportError = async (exit: Exit.Exit<unknown, unknown>): Promise<void> => {
        try {
          await close(exit)