Function closeAndReportError

packages/effect/src/Stream.ts:11123–11129

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

        return closePromise
      }
      const closeAndReportError = async (exit: Exit.Exit<unknown, unknown>): Promise<void> => {
        try {
          await close(exit)
        } catch (error) {
          await runPromise(Effect.logError("Suppressed error while closing Stream async iterator", error))
        }
      }
      return {
        async next(): Promise<IteratorResult<A>> {
          if (closePromise) return closePromise