Wrap the given SourceSource with a SourceSource that will restart it when it fails using an exponential backoff.

Error handling


def onFailuresWithBackoff[T](minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double)(sourceFactory: () => Source[T, _]): Source[T, NotUsed]
def onFailuresWithBackoff[T](minBackoff: FiniteDuration,maxBackoff: FiniteDuration,randomFactor: Double,maxRestarts: Int)(sourceFactory: () => Source[T, _]): Source[T, NotUsed]


This SourceSource will never emit a failure, since the failure of the wrapped SourceSource is always handled by restarting. The wrapped SourceSource can be cancelled by cancelling this SourceSource. When that happens, the wrapped SourceSource, if currently running will be cancelled, and it will not be restarted. This can be triggered simply by the downstream cancelling, or externally by introducing a KillSwitchKillSwitch right after this SourceSource in the graph.

Reactive Streams semantics

emits when the wrapped source emits

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.