Package akka.stream

Class Supervision$


  • public class Supervision$
    extends java.lang.Object
    • 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.
      • 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<java.lang.Throwable,​Supervision.Directive> stoppingDecider()
        Scala API: Decider that returns Stop for all exceptions.
      • resumingDecider

        public scala.Function1<java.lang.Throwable,​Supervision.Directive> resumingDecider()
        Scala API: Decider that returns Resume for all exceptions.
      • restartingDecider

        public scala.Function1<java.lang.Throwable,​Supervision.Directive> restartingDecider()
        Scala API: Decider that returns Restart for all exceptions.