akka.stream

Class Supervision$

java.lang.Object

akka.stream.Supervision$

public class Supervision$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static Supervision$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Supervision$()

Method Summary

Modifier and Type	Method and Description
Function<java.lang.Throwable,Supervision.Directive>	getRestartingDecider() Java API: Decider function that returns restart() for all exceptions.
Function<java.lang.Throwable,Supervision.Directive>	getResumingDecider() Java API: Decider function that returns resume() for all exceptions.
Function<java.lang.Throwable,Supervision.Directive>	getStoppingDecider() Java API: Decider function that returns stop() for all exceptions.
Supervision.Restart$	restart() Java API: The element is dropped and the stream continues after restarting the stage if application code for processing an element throws an exception.
scala.Function1<java.lang.Throwable,Supervision.Directive>	restartingDecider() Scala API: Decider that returns Restart for all exceptions.
Supervision.Resume$	resume() Java API: The element is dropped and the stream continues if application code for processing an element throws an exception.
scala.Function1<java.lang.Throwable,Supervision.Directive>	resumingDecider() Scala API: Decider that returns Resume for all exceptions.
Supervision.Stop$	stop() Java API: The stream will be completed with failure if application code for processing an element throws an exception.
scala.Function1<java.lang.Throwable,Supervision.Directive>	stoppingDecider() Scala API: Decider that returns Stop for all exceptions.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Supervision$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Supervision$

public Supervision$()

Method Detail

stop

public Supervision.Stop$ stop()

Java API: The stream will be completed with failure if application code for processing an element throws an exception.

Returns:

(undocumented)

resume

public Supervision.Resume$ resume()

Java API: The element is dropped and the stream continues if application code for processing an element throws an exception.

Returns:

(undocumented)

restart

public Supervision.Restart$ restart()

Java API: The element is dropped and the stream continues after restarting the stage if application code for processing an element throws an exception. Restarting a stage means that any accumulated state is cleared. This is typically performed by creating a new instance of the stage.

Returns:

(undocumented)

stoppingDecider

public scala.Function1<java.lang.Throwable,Supervision.Directive> stoppingDecider()

Scala API: Decider that returns Stop for all exceptions.

Returns:

(undocumented)

getStoppingDecider

public Function<java.lang.Throwable,Supervision.Directive> getStoppingDecider()

Java API: Decider function that returns stop() for all exceptions.

Returns:

(undocumented)

resumingDecider

public scala.Function1<java.lang.Throwable,Supervision.Directive> resumingDecider()

Scala API: Decider that returns Resume for all exceptions.

Returns:

(undocumented)

getResumingDecider

public Function<java.lang.Throwable,Supervision.Directive> getResumingDecider()

Java API: Decider function that returns resume() for all exceptions.

Returns:

(undocumented)

restartingDecider

public scala.Function1<java.lang.Throwable,Supervision.Directive> restartingDecider()

Scala API: Decider that returns Restart for all exceptions.

Returns:

(undocumented)

getRestartingDecider

public Function<java.lang.Throwable,Supervision.Directive> getRestartingDecider()

Java API: Decider function that returns restart() for all exceptions.

Returns:

(undocumented)