Package akka.actor.testkit.typed.javadsl

Class TestInbox<T>

java.lang.Object

akka.actor.testkit.typed.javadsl.TestInbox<T>

Direct Known Subclasses:

TestInboxImpl

public abstract class TestInbox<T>
extends java.lang.Object

The actor ref of the inbox

Constructor Summary

Constructors

Constructor	Description
TestInbox()

Method Summary

Modifier and Type	Method	Description
static <T> TestInbox<T>	create()
static <T> TestInbox<T>	create(java.lang.String name)
abstract TestInbox<T>	expectMessage(T expectedMessage)	Assert and remove the the oldest message.
java.util.List<T>	getAllReceived()	Collect all messages in the inbox and clear it out
abstract ActorRef<T>	getRef()
abstract boolean	hasMessages()
protected abstract scala.collection.immutable.Seq<T>	internalReceiveAll()
abstract T	receiveMessage()	Get and remove the oldest message

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestInbox

public TestInbox()

Method Detail

create

public static <T> TestInbox<T> create(java.lang.String name)

create

public static <T> TestInbox<T> create()

getRef

public abstract ActorRef<T> getRef()

receiveMessage

public abstract T receiveMessage()

Get and remove the oldest message

Returns:

(undocumented)

expectMessage

public abstract TestInbox<T> expectMessage(T expectedMessage)

Assert and remove the the oldest message.

Parameters:

expectedMessage - (undocumented)

Returns:

(undocumented)

getAllReceived

public java.util.List<T> getAllReceived()

Collect all messages in the inbox and clear it out

Returns:

(undocumented)

internalReceiveAll

protected abstract scala.collection.immutable.Seq<T> internalReceiveAll()

hasMessages

public abstract boolean hasMessages()