Package org.apache.pekko.stream

Class Supervision$

java.lang.Object

org.apache.pekko.stream.Supervision$

public class Supervision$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final 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<Throwable,Supervision.Directive>	getRestartingDecider()	Java API: Decider function that returns restart() for all exceptions.
Function<Throwable,Supervision.Directive>	getResumingDecider()	Java API: Decider function that returns resume() for all exceptions.
Function<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 operator if application code for processing an element throws an exception.
scala.Function1<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<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<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 Details

MODULE$

public static final Supervision$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

Supervision$

public Supervision$()

Method Details

stop

public Supervision.Stop$ stop()

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

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.

restart

public Supervision.Restart$ restart()

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

stoppingDecider

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

Scala API: Decider that returns Stop for all exceptions.

getStoppingDecider

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

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

resumingDecider

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

Scala API: Decider that returns Resume for all exceptions.

getResumingDecider

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

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

restartingDecider

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

Scala API: Decider that returns Restart for all exceptions.

getRestartingDecider

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

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