Class RestartWithBackoffSink<T>

    • Constructor Detail

      • RestartWithBackoffSink

        public RestartWithBackoffSink​(scala.Function0<Sink<T,​?>> sinkFactory,
                                      scala.concurrent.duration.FiniteDuration minBackoff,
                                      scala.concurrent.duration.FiniteDuration maxBackoff,
                                      double randomFactor,
                                      int maxRestarts)