Module com.github.tix.skimp

Package com.github.tix320.skimp.api.general

Class IntervalRepeater<T>

java.lang.Object

com.github.tix320.skimp.api.general.IntervalRepeater<T>

public final class IntervalRepeater<T>
extends Object

Constructor Summary

Constructors

Constructor	Description
IntervalRepeater(Supplier<T> action, Duration initialDuration, Function<Duration,Duration> accumulator)

Method Summary

Modifier and Type	Method	Description
IntervalRepeater<T>	copyByInitialState()
T	doNext()
Optional<T>	doUntilSuccess(int maxCount)
static IntervalRepeater<None>	every(Runnable runnable, Duration duration)
static <T> IntervalRepeater<T>	every(Supplier<T> runnable, Duration duration)
static IntervalRepeater<None>	raising(Runnable runnable, Duration initial, Duration raise)
static <T> IntervalRepeater<T>	raising(Supplier<T> runnable, Duration initial, Duration raise)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IntervalRepeater

public IntervalRepeater(Supplier<T> action,
                        Duration initialDuration,
                        Function<Duration,Duration> accumulator)

Method Detail

doNext

public T doNext()
         throws InterruptedException

Throws:

InterruptedException

doUntilSuccess

public Optional<T> doUntilSuccess(int maxCount)
                           throws InterruptedException

Throws:

InterruptedException

copyByInitialState

public IntervalRepeater<T> copyByInitialState()

every

public static <T> IntervalRepeater<T> every(Supplier<T> runnable,
                                            Duration duration)

every

public static IntervalRepeater<None> every(Runnable runnable,
                                           Duration duration)

raising

public static <T> IntervalRepeater<T> raising(Supplier<T> runnable,
                                              Duration initial,
                                              Duration raise)

raising

public static IntervalRepeater<None> raising(Runnable runnable,
                                             Duration initial,
                                             Duration raise)