Package akka.stream

Class 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 Detail

      • MODULE$

        public static final Supervision$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • Supervision$

        public Supervision$()
    • Method Detail

      • 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)