object Supervision
- Alphabetic
- By Inheritance
- Supervision
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
val
getRestartingDecider: Function[Throwable, Directive]
Java API: Decider function that returns #restart for all exceptions.
-
val
getResumingDecider: Function[Throwable, Directive]
Java API: Decider function that returns #resume for all exceptions.
-
val
getStoppingDecider: Function[Throwable, Directive]
Java API: Decider function that returns #stop for all exceptions.
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
restart: Restart.type
Java API: The element is dropped and the stream continues after restarting the operator if application code for processing an element throws an exception.
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.
- val restartingDecider: Decider with Function[Throwable, Directive]
-
def
resume: Resume.type
Java API: The element is dropped and the stream continues if application code for processing an element throws an exception.
- val resumingDecider: Decider with Function[Throwable, Directive]
-
def
stop: Stop.type
Java API: The stream will be completed with failure if application code for processing an element throws an exception.
- val stoppingDecider: Decider with Function[Throwable, Directive]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
object
Restart extends Directive with Product with 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.
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.
-
object
Resume extends Directive with Product with Serializable
Scala API: The element is dropped and the stream continues if application code for processing an element throws an exception.
-
object
Stop extends Directive with Product with Serializable
Scala API: The stream will be completed with failure if application code for processing an element throws an exception.