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
- Alphabetic
- By Inheritance
- Aggregator
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Value Members
-
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.
-
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.
-
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.
-
def
receive: Receive
Receive function for handling the aggregations.
-
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.