Function loop

packages/effect/src/Stream.ts:5898–5909

()

  unwrap(Effect.map(Schedule.toStepWithMetadata(schedule), (step) => {
    let meta = Schedule.CurrentMetadata.defaultValue()
    const loop = (): Stream<A, E | E2, R | R2> =>
      catch_(
        provideServiceEffect(self, Schedule.CurrentMetadata, Effect.sync(() => meta)),
        (error) =>
          unwrap(Pull.catchDone(
            Effect.map(step(error), (meta_) => {
              meta = meta_
              return unwrap(Effect.as(Effect.yieldNow, loop()))
            }),
            () => Effect.succeed(fail(error))
          ))
      )
    return loop()
  }))