Package org.apache.pekko.stream

Class Supervision.Restart$

java.lang.Object
org.apache.pekko.stream.Supervision.Restart$
All Implemented Interfaces:
Serializable, Supervision.Directive, scala.Equals, scala.Product
Enclosing class:
Supervision
public static class Supervision.Restart$ extends Object implements Supervision.Directive, scala.Product, Serializable
Scala 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.
See Also:

  • Field Details

    • MODULE$

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

  • Constructor Details

    • Restart$

      public Restart$()

  • Method Details

    • productPrefix

      public String productPrefix()
      Specified by:
      productPrefix in interface scala.Product

    • productArity

      public int productArity()
      Specified by:
      productArity in interface scala.Product

    • productElement

      public Object productElement(int x$1)
      Specified by:
      productElement in interface scala.Product

    • productIterator

      public scala.collection.Iterator<Object> productIterator()
      Specified by:
      productIterator in interface scala.Product

    • canEqual

      public boolean canEqual(Object x$1)
      Specified by:
      canEqual in interface scala.Equals

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object