object Behavior
- Source
- Behavior.scala
- Alphabetic
- By Inheritance
- Behavior
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- implicit final class BehaviorDecorators[T] extends AnyVal
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
canonicalize[T](behavior: Behavior[T], current: Behavior[T], ctx: TypedActorContext[T]): Behavior[T]
Given a possibly special behavior (same or unhandled) and a “current” behavior (which defines the meaning of encountering a
same
behavior) this method computes the next behavior, suitable for passing a message or signal.Given a possibly special behavior (same or unhandled) and a “current” behavior (which defines the meaning of encountering a
same
behavior) this method computes the next behavior, suitable for passing a message or signal.- Annotations
- @tailrec()
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
def
empty[T]: Behavior[T]
A behavior that treats every incoming message as unhandled.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
existsInStack[T](behavior: Behavior[T])(p: (Behavior[T]) ⇒ Boolean): Boolean
Go through the behavior stack and apply a predicate to see if any nested behavior satisfies it.
Go through the behavior stack and apply a predicate to see if any nested behavior satisfies it. The stack must not contain any unstarted deferred behavior or an
IllegalArgumentException
will be thrown. -
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
ignore[T]: Behavior[T]
A behavior that ignores every incoming message and returns “same”.
-
def
interpretMessage[T](behavior: Behavior[T], ctx: TypedActorContext[T], msg: T): Behavior[T]
Execute the behavior with the given message
-
def
interpretSignal[T](behavior: Behavior[T], ctx: TypedActorContext[T], signal: Signal): Behavior[T]
Execute the behavior with the given signal
-
def
isAlive[T](behavior: Behavior[T]): Boolean
Returns true if the given behavior is not stopped.
-
def
isDeferred[T](behavior: Behavior[T]): Boolean
Returns true if the given behavior is the special
Unhandled
marker. -
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isUnhandled[T](behavior: Behavior[T]): Boolean
Returns true if the given behavior is the special
unhandled
marker. -
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
same[T]: Behavior[T]
Return this behavior from message processing in order to advise the system to reuse the previous behavior.
Return this behavior from message processing in order to advise the system to reuse the previous behavior. This is provided in order to avoid the allocation overhead of recreating the current behavior where that is not necessary.
-
def
start[T](behavior: Behavior[T], ctx: TypedActorContext[T]): Behavior[T]
Starts deferred behavior and nested deferred behaviors until all deferred behaviors in the stack are started and then the resulting behavior is returned.
-
def
stopped[T](postStop: () ⇒ Unit): Behavior[T]
Return this behavior from message processing to signal that this actor shall terminate voluntarily.
Return this behavior from message processing to signal that this actor shall terminate voluntarily. If this actor has created child actors then these will be stopped as part of the shutdown procedure.
The PostStop signal that results from stopping this actor will be passed to the given
postStop
behavior. All other messages and signals will effectively be ignored. -
def
stopped[T]: Behavior[T]
Return this behavior from message processing to signal that this actor shall terminate voluntarily.
Return this behavior from message processing to signal that this actor shall terminate voluntarily. If this actor has created child actors then these will be stopped as part of the shutdown procedure.
The PostStop signal that results from stopping this actor will be passed to the current behavior. All other messages and signals will effectively be ignored.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
unhandled[T]: Behavior[T]
Return this behavior from message processing in order to advise the system to reuse the previous behavior, including the hint that the message has not been handled.
Return this behavior from message processing in order to advise the system to reuse the previous behavior, including the hint that the message has not been handled. This hint may be used by composite behaviors that delegate (partial) handling to other behaviors.
-
def
validateAsInitial[T](behavior: Behavior[T]): Behavior[T]
Validate the given behavior as a suitable initial actor behavior; most notably the behavior can neither be
same
norunhandled
.Validate the given behavior as a suitable initial actor behavior; most notably the behavior can neither be
same
norunhandled
. Starting out with aStopped
behavior is allowed, though. -
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( ... )