Class RestartWithBackoffSource<T>

    • Constructor Detail

      • RestartWithBackoffSource

        public RestartWithBackoffSource​(scala.Function0<Source<T,​?>> sourceFactory,
                                        scala.concurrent.duration.FiniteDuration minBackoff,
                                        scala.concurrent.duration.FiniteDuration maxBackoff,
                                        double randomFactor,
                                        boolean onlyOnFailures,
                                        int maxRestarts)