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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Supervision.Directive
static class	Supervision.Restart$	Scala API: The element is dropped and the stream continues after restarting the operator if application code for processing an element throws an exception.
static class	Supervision.Resume$	Scala API: The element is dropped and the stream continues if application code for processing an element throws an exception.
static class	Supervision.Stop$

Constructor Summary

Constructors

Constructor	Description
Supervision()

Method Summary

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

Constructor Detail

Supervision

public Supervision()

Method Detail

stop

public static Supervision.Stop$ stop()

resume

public static Supervision.Resume$ resume()

restart

public static Supervision.Restart$ restart()

stoppingDecider

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

Scala API: Decider that returns Stop for all exceptions.

Returns:

(undocumented)

getStoppingDecider

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

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

Returns:

(undocumented)

resumingDecider

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

Scala API: Decider that returns Resume for all exceptions.

Returns:

(undocumented)

getResumingDecider

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

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

Returns:

(undocumented)

restartingDecider

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

Scala API: Decider that returns Restart for all exceptions.

Returns:

(undocumented)

getRestartingDecider

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

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

Returns:

(undocumented)