Function next

packages/effect/src/Stream.ts:11131–11161

()

      }
      return {
        async next(): Promise<IteratorResult<A>> {
          if (closePromise) return closePromise
          if (currentIter) {
            const next = currentIter.next()
            if (!next.done) return next
            currentIter = undefined
          }
          const fiber = runFork(
            pull ??
              Effect.flatMap(Channel.toPullScoped(self.channel, scope), (nextPull) => {
                pull = nextPull
                return nextPull
              })
          )
          currentFiber = fiber
          const exit = await runPromise(Fiber.await(fiber))
          if (currentFiber === fiber) {
            currentFiber = undefined
          }
          if (Exit.isSuccess(exit)) {
            currentIter = exit.value[Symbol.iterator]()
            return currentIter.next()
          } else if (Pull.isDoneCause(exit.cause)) {
            return close(Exit.void)
          }
          if (closePromise && Cause.hasInterruptsOnly(exit.cause)) {
            return closePromise
          }
          await closeAndReportError(exit)
          throw Cause.squash(exit.cause)
        },
        return() {
          return close(Exit.void)
        },