akka.testkit
Class JavaTestKit.ReceiveWhile<T>
java.lang.Object
akka.testkit.JavaTestKit.ReceiveWhile<T>
- Enclosing class:
- JavaTestKit
public abstract class JavaTestKit.ReceiveWhile<T>
- extends java.lang.Object
Receive a series of messages until one does not match the given
match
function or the idle timeout is met (disabled by
default) or the overall maximum duration is elapsed. Returns the sequence
of messages.
Note that it is not an error to hit the max
duration in this
case.
One possible use of this method is for testing whether messages of certain
characteristics are generated at a certain rate.
Method Summary |
T[] |
get()
|
protected abstract T |
match(java.lang.Object msg)
|
protected java.lang.RuntimeException |
noMatch()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JavaTestKit.ReceiveWhile
public JavaTestKit.ReceiveWhile(java.lang.Class<T> clazz)
JavaTestKit.ReceiveWhile
public JavaTestKit.ReceiveWhile(java.lang.Class<T> clazz,
scala.concurrent.duration.Duration max)
JavaTestKit.ReceiveWhile
public JavaTestKit.ReceiveWhile(java.lang.Class<T> clazz,
scala.concurrent.duration.Duration max,
int messages)
JavaTestKit.ReceiveWhile
public JavaTestKit.ReceiveWhile(java.lang.Class<T> clazz,
scala.concurrent.duration.Duration max,
scala.concurrent.duration.Duration idle,
int messages)
match
protected abstract T match(java.lang.Object msg)
throws java.lang.Exception
- Throws:
java.lang.Exception
noMatch
protected java.lang.RuntimeException noMatch()
get
public T[] get()