final case class SynchronousSelf[T](f: (ActorRef[T]) ⇒ Behavior[T]) extends Behavior[T] with Product with Serializable
This behavior allows sending messages to itself without going through the Actor’s mailbox. A message sent like this will be processed before the next message is taken out of the mailbox. In case of Actor failures outstanding messages that were sent to the synchronous self reference will be lost.
This decorator is useful for passing messages between the left and right sides of And and Or combinators.
- Source
- ScalaDSL.scala
- Alphabetic
- By Inheritance
- SynchronousSelf
- Serializable
- Serializable
- Product
- Equals
- Behavior
- AnyRef
- Any
- by BehaviorDecorators
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
&&(other: Behavior[T]): Behavior[T]
Combine the two behaviors such that incoming messages are distributed to both of them, each one evolving its state independently.
Combine the two behaviors such that incoming messages are distributed to both of them, each one evolving its state independently.
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to BehaviorDecorators[T] performed by method BehaviorDecorators in akka.typed.ScalaDSL.
- Definition Classes
- BehaviorDecorators
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to any2stringadd[SynchronousSelf[T]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (SynchronousSelf[T], B)
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to ArrowAssoc[SynchronousSelf[T]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
val
behavior: Behavior[T]
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to BehaviorDecorators[T] performed by method BehaviorDecorators in akka.typed.ScalaDSL.
- Definition Classes
- BehaviorDecorators
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
ensuring(cond: (SynchronousSelf[T]) ⇒ Boolean, msg: ⇒ Any): SynchronousSelf[T]
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to Ensuring[SynchronousSelf[T]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (SynchronousSelf[T]) ⇒ Boolean): SynchronousSelf[T]
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to Ensuring[SynchronousSelf[T]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): SynchronousSelf[T]
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to Ensuring[SynchronousSelf[T]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): SynchronousSelf[T]
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to Ensuring[SynchronousSelf[T]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val f: (ActorRef[T]) ⇒ Behavior[T]
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to StringFormat[SynchronousSelf[T]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
management(ctx: ActorContext[T], msg: 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.- Definition Classes
- SynchronousSelf → Behavior
-
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.- Definition Classes
- SynchronousSelf → Behavior
-
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
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- SynchronousSelf → AnyRef → Any
-
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
widen[U >: T](matcher: PartialFunction[U, T]): Behavior[U]
Widen the type of this Behavior by providing a filter function that permits only a subtype of the widened set of messages.
Widen the type of this Behavior by providing a filter function that permits only a subtype of the widened set of messages.
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to BehaviorDecorators[T] performed by method BehaviorDecorators in akka.typed.ScalaDSL.
- Definition Classes
- BehaviorDecorators
-
def
||(other: Behavior[T]): Behavior[T]
Combine the two behaviors such that incoming messages are given first to the left behavior and are then only passed on to the right behavior if the left one returned Unhandled.
Combine the two behaviors such that incoming messages are given first to the left behavior and are then only passed on to the right behavior if the left one returned Unhandled.
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to BehaviorDecorators[T] performed by method BehaviorDecorators in akka.typed.ScalaDSL.
- Definition Classes
- BehaviorDecorators
-
def
→[B](y: B): (SynchronousSelf[T], B)
- Implicit
- This member is added by an implicit conversion from SynchronousSelf[T] to ArrowAssoc[SynchronousSelf[T]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc