servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/RepeatStrategies.java
/**
     * Creates a new repeat function that adds the passed constant {@link Duration} as delay between repeats.
     *
     * @param delay Constant {@link Duration} of delay between repeats.
     * @param timerExecutor {@link Executor} to be used to schedule timers for delay.
     *
     * @return An {@link IntFunction} to be used for repeats which given a repeat count returns a {@link Completable}
     * that terminates successfully when the source has to be repeated or terminates with error if the source should not
     * be repeated.
     */
Creates a new repeat function that adds the passed constant  Duration as delay between repeats.
@param delay Constant  Duration of delay between repeats.
@param timerExecutor  Executor to be used to schedule timers for delay.

@return An  IntFunction to be used for repeats which given a repeat count returns a  Completable
that terminates successfully when the source has to be repeated or terminates with error if the source should not
be repeated.
Creates a new repeat function that adds the passed constant Duration as delay between repeats . @param delay Constant Duration of delay between repeats . @param timerExecutor Executor to be used to schedule timers for delay . @return An IntFunction to be used for repeats which given a repeat count returns a Completable that terminates successfully when the source has to be repeated or terminates with error if the source should not be repeated .
public static IntFunction<Completable> repeatWithConstantBackoffFullJitter(final Duration delay,
                                                                               final Executor timerExecutor) {
        requireNonNull(timerExecutor);
        final long delayNanos = delay.toNanos();
        checkFullJitter(delayNanos);
        return repeatCount -> timerExecutor.timer(current().nextLong(0, delayNanos), NANOSECONDS);
    }
public static IntFunction < Completable > repeatWithConstantBackoffFullJitter ( final Duration delay , final Executor timerExecutor ) { requireNonNull ( timerExecutor ) ; final long delayNanos = delay . toNanos ( ) ; checkFullJitter ( delayNanos ) ; return repeatCount -> timerExecutor . timer ( current ( ) . nextLong ( 0 , delayNanos ) , NANOSECONDS ) ; }
Creates a new repeat function that adds the passed constant {@link Duration} as delay between repeats.
Creates a new repeat function that adds the passed constant { @link Duration } as delay between repeats .