Class Inbox.InboxActor

    • Constructor Detail

      • InboxActor

        public InboxActor​(int size)
    • Method Detail

      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • clientPredicate

        public scala.Function1<Inbox.Query,​java.lang.Object> clientPredicate()
      • clients

        public scala.collection.mutable.Queue<Inbox.Query> clients()
      • clientsByTimeout

        public scala.collection.immutable.TreeSet<Inbox.Query> clientsByTimeout()
      • clientsByTimeout_$eq

        public void clientsByTimeout_$eq​(scala.collection.immutable.TreeSet<Inbox.Query> x$1)
      • clients_$eq

        public void clients_$eq​(scala.collection.mutable.Queue<Inbox.Query> x$1)
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • currentDeadline

        public scala.Option<scala.Tuple2<scala.concurrent.duration.Deadline,​Cancellable>> currentDeadline()
      • currentDeadline_$eq

        public void currentDeadline_$eq​(scala.Option<scala.Tuple2<scala.concurrent.duration.Deadline,​Cancellable>> x$1)
      • currentMsg

        public java.lang.Object currentMsg()
      • currentMsg_$eq

        public void currentMsg_$eq​(java.lang.Object x$1)
      • currentSelect_$eq

        public void currentSelect_$eq​(Inbox.Select x$1)
      • enqueueMessage

        public void enqueueMessage​(java.lang.Object msg)
      • enqueueQuery

        public void enqueueQuery​(Inbox.Query q)
      • messagePredicate

        public scala.Function1<java.lang.Object,​java.lang.Object> messagePredicate()
      • messages

        public scala.collection.mutable.Queue<java.lang.Object> messages()
      • printedWarning

        public boolean printedWarning()
      • printedWarning_$eq

        public void printedWarning_$eq​(boolean x$1)
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)