final case class Restarter[T, Thr <: Throwable](initialBehavior: Behavior[T], resume: Boolean)(implicit evidence$1: ClassTag[Thr]) extends Behavior[T] with Product with Serializable
Simple supervision strategy that restarts the underlying behavior for all failures of type Thr.
FIXME add limited restarts and back-off (with limited buffering or vacation responder) FIXME write tests that ensure that all Behaviors are okay with getting PostRestart as first signal
- Source
- Restarter.scala
- Alphabetic
- By Inheritance
- Restarter
- Serializable
- Serializable
- Product
- Equals
- Behavior
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (Restarter[T, Thr], B)
-
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
- @throws( ... )
- def ensuring(cond: (Restarter[T, Thr]) ⇒ Boolean, msg: ⇒ Any): Restarter[T, Thr]
- def ensuring(cond: (Restarter[T, Thr]) ⇒ Boolean): Restarter[T, Thr]
- def ensuring(cond: Boolean, msg: ⇒ Any): Restarter[T, Thr]
- def ensuring(cond: Boolean): Restarter[T, Thr]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- val initialBehavior: Behavior[T]
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
management(ctx: ActorContext[T], signal: Signal): Behavior[T]
Process an incoming Signal and return the next behavior.
Process an incoming Signal and return the next behavior. This means that all lifecycle hooks, ReceiveTimeout, Terminated and Failed messages can initiate a behavior change.
The returned behavior can in addition to normal behaviors be one of the canned special objects:
* returning
Stoppedwill terminate this Behavior * returningSamedesignates to reuse the current Behavior * returningUnhandledkeeps the same Behavior and signals that the message was not yet handledCode calling this method should use Behavior$
canonicalizeto replace the special objects with real Behaviors. -
def
message(ctx: ActorContext[T], msg: T): Behavior[T]
Process an incoming message and return the next behavior.
Process an incoming message and return the next behavior.
The returned behavior can in addition to normal behaviors be one of the canned special objects:
* returning
Stoppedwill terminate this Behavior * returningSamedesignates to reuse the current Behavior * returningUnhandledkeeps the same Behavior and signals that the message was not yet handledCode calling this method should use Behavior$
canonicalizeto replace the special objects with real Behaviors. -
def
narrow[U <: T]: Behavior[U]
Narrow the type of this Behavior, which is always a safe operation.
Narrow the type of this Behavior, which is always a safe operation. This method is necessary to implement the contravariant nature of Behavior (which cannot be expressed directly due to type inference problems).
- Definition Classes
- Behavior
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- val resume: Boolean
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- def →[B](y: B): (Restarter[T, Thr], B)