Method next

packages/effect/src/internal/schedule.ts:165–201

(input: In)

  }

  next(input: In): Effect.Effect<Out, Option.Option<never>, R> {
    return pipe(
      core.map(ref.get(this.ref), (tuple) => tuple[1]),
      core.flatMap((state) =>
        pipe(
          Clock.currentTimeMillis,
          core.flatMap((now) =>
            pipe(
              core.suspend(() => this.schedule.step(now, input, state)),
              core.flatMap(([state, out, decision]) => {
                const setState = ref.set(this.ref, [Option.some(out), state] as const)
                if (ScheduleDecision.isDone(decision)) {
                  return setState.pipe(
                    core.zipRight(core.fail(Option.none()))
                  )
                }
                const millis = Intervals.start(decision.intervals) - now
                if (millis <= 0) {
                  return setState.pipe(
                    core.zipRight(updateInfo(this.iterationMeta, now, input, out)),
                    core.as(out)
                  )
                }
                const duration = Duration.millis(millis)
                return pipe(
                  setState,
                  core.zipRight(updateInfo(this.iterationMeta, now, input, out)),
                  core.zipRight(effect.sleep(duration)),
                  core.as(out)
                )
              })
            )
          )
        )
      )
    )
  }
}

/** @internal */