Package akka.stream

Class Supervision$

java.lang.Object

akka.stream.Supervision$

public class Supervision$
extends java.lang.Object

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Supervision$()

Method Summary

Modifier and Type	Method	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()
scala.Function1<java.lang.Throwable,Supervision.Directive>	restartingDecider()	Scala API: Decider that returns Restart for all exceptions.
Supervision.Resume$	resume()
scala.Function1<java.lang.Throwable,Supervision.Directive>	resumingDecider()	Scala API: Decider that returns Resume for all exceptions.
Supervision.Stop$	stop()
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()

resume

public Supervision.Resume$ resume()

restart

public Supervision.Restart$ restart()

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)