Class BehaviorImpl.ReceiveMessageBehavior<T>

  • Enclosing class:
    BehaviorImpl

    public static class BehaviorImpl.ReceiveMessageBehavior<T>
    extends ExtensibleBehavior<T>
    Similar to BehaviorImpl.ReceiveBehavior however onMessage does not accept context. We implement it separately in order to be able to avoid wrapping each function in another function which drops the context parameter.
    • Constructor Detail

      • ReceiveMessageBehavior

        public ReceiveMessageBehavior​(scala.Function1<T,​Behavior<T>> onMessage,
                                      scala.PartialFunction<scala.Tuple2<ActorContext<T>,​Signal>,​Behavior<T>> onSignal)
    • Method Detail

      • onMessage

        public scala.Function1<T,​Behavior<T>> onMessage()
      • receive

        public Behavior<T> receive​(TypedActorContext<T> ctx,
                                   T msg)
        Description copied from class: ExtensibleBehavior
        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 stopped will terminate this Behavior * returning same designates to reuse the current Behavior * returning unhandled keeps the same Behavior and signals that the message was not yet handled

        Code calling this method should use Behavior$ canonicalize to replace the special objects with real Behaviors.

        Specified by:
        receive in class ExtensibleBehavior<T>
      • receiveSignal

        public Behavior<T> receiveSignal​(TypedActorContext<T> ctx,
                                         Signal msg)
        Description copied from class: ExtensibleBehavior
        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 stopped will terminate this Behavior * returning same designates to reuse the current Behavior * returning unhandled keeps the same Behavior and signals that the message was not yet handled

        Code calling this method should use Behavior$ canonicalize to replace the special objects with real Behaviors.

        Specified by:
        receiveSignal in class ExtensibleBehavior<T>
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object