fixed<I> static method

Schedule<NoEnv, Never, I, int> fixed<I>(
  1. Duration duration
)

Implementation

static Schedule<NoEnv, Never, I, int> fixed<I>(Duration duration) =>
    Schedule._(
      (input, count, lastTick) => IO(
        () => _remainingWindow(lastTick, duration),
      ).flatMap(
        (_) => _.match(
          () => ZIO.succeed(count),
          (duration) => ZIO.sleepIO(duration).as(count),
        ),
      ),
    );