Packages

t

akka.contrib.pattern

Aggregator

trait Aggregator extends AnyRef

The aggregator is to be mixed into an actor for the aggregator behavior.

Self Type
Aggregator with Actor
Annotations
@deprecated
Deprecated

(Since version 2.5.0) Feel free to copy

Source
Aggregator.scala
Linear Supertypes
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Aggregator
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def expect(fn: Receive): Receive

    Adds the partial function to the receive set and keeping it in the receive set till removed.

    Adds the partial function to the receive set and keeping it in the receive set till removed.

    fn

    The receive function.

    returns

    The same receive function.

  2. def expectOnce(fn: Receive): Receive

    Adds the partial function to the receive set, to be removed on first match.

    Adds the partial function to the receive set, to be removed on first match.

    fn

    The receive function.

    returns

    The same receive function.

  3. def handleMessage(msg: Any): Boolean

    Handles messages and matches against the expect list.

    Handles messages and matches against the expect list.

    msg

    The message to be handled.

    returns

    true if message is successfully processed, false otherwise.

  4. def receive: Receive

    Receive function for handling the aggregations.

  5. def unexpect(fn: Receive): Boolean

    Removes the partial function from the receive set.

    Removes the partial function from the receive set.

    fn

    The receive function.

    returns

    True if the partial function is removed, false if not found.