Function repeatEffectWithSchedule

packages/effect/src/internal/stream.ts:5430–5451

(
  effect: Effect.Effect<A, E, R>,
  schedule: Schedule.Schedule<X, A0, R2>
)

/** @internal */
export const repeatEffectWithSchedule = <A, E, R, X, A0 extends A, R2>(
  effect: Effect.Effect<A, E, R>,
  schedule: Schedule.Schedule<X, A0, R2>
): Stream.Stream<A, E, R | R2> =>
  flatMap(
    fromEffect(Effect.zip(effect, Schedule.driver(schedule))),
    ([a, driver]) => {
      const provideLastIterationInfo = Effect.provideServiceEffect(
        Schedule.CurrentIterationMetadata,
        Ref.get(driver.iterationMeta)
      )
      return concat(
        succeed(a),
        unfoldEffect(a, (s) =>
          Effect.matchEffect(driver.next(s as A0), {
            onFailure: Effect.succeed,
            onSuccess: () =>
              Effect.map(provideLastIterationInfo(effect), (nextA) => Option.some([nextA, nextA] as const))
          }))
      )
    }
  )

/** @internal */
export const retry = dual<