Package akka.persistence.testkit.scaladsl

Interface ExpectOps<U>

All Known Implementing Classes:

PersistenceTestKit, SnapshotTestKit

public interface ExpectOps<U>

Method Summary

Modifier and Type	Method	Description
<A> A	expectNextPersisted(java.lang.String persistenceId, A event)	Check that next persisted in storage for particular persistence id event/snapshot was event.
<A> A	expectNextPersisted(java.lang.String persistenceId, A event, scala.concurrent.duration.FiniteDuration max)	Check for max time that next persisted in storage for particular persistence id event/snapshot was event.
<A> A	expectNextPersistedClass(java.lang.String persistenceId, java.lang.Class<A> cla)	Check that next persisted in storage for particular persistence id event/snapshot has expected type.
<A> A	expectNextPersistedClass(java.lang.String persistenceId, java.lang.Class<A> cla, scala.concurrent.duration.FiniteDuration max)	Check for max time that next persisted in storage for particular persistence id event/snapshot has expected type.
<A> A	expectNextPersistedType(java.lang.String persistenceId, scala.concurrent.duration.FiniteDuration max, scala.reflect.ClassTag<A> t)	Check for max time that next persisted in storage for particular persistence id event/snapshot has expected type.
<A> A	expectNextPersistedType(java.lang.String persistenceId, scala.reflect.ClassTag<A> t)	Check that next persisted in storage for particular persistence id event/snapshot has expected type.
void	expectNothingPersisted(java.lang.String persistenceId)	Check that nothing was persisted in storage for particular persistence id.
void	expectNothingPersisted(java.lang.String persistenceId, scala.concurrent.duration.FiniteDuration max)	Check for max time that nothing was persisted in storage for particular persistence id.
scala.Option<java.lang.Object>	getItem(java.lang.String persistenceId, int nextInd)
scala.concurrent.duration.FiniteDuration	maxTimeout()
scala.concurrent.duration.FiniteDuration	pollInterval()
TestKitBase	probe()
<A> scala.collection.immutable.Seq<A>	receivePersisted(java.lang.String persistenceId, int n, java.lang.Class<A> cla)	Receive next n events/snapshots that have been persisted in the storage.
<A> scala.collection.immutable.Seq<A>	receivePersisted(java.lang.String persistenceId, int n, java.lang.Class<A> cla, scala.concurrent.duration.FiniteDuration max)	Receive for max time next n events/snapshots that have been persisted in the storage.
<A> scala.collection.immutable.Seq<A>	receivePersisted(java.lang.String persistenceId, int n, scala.concurrent.duration.FiniteDuration max, scala.reflect.ClassTag<A> t)	Receive for max time next n events/snapshots that have been persisted in the storage.
<A> scala.collection.immutable.Seq<A>	receivePersisted(java.lang.String persistenceId, int n, scala.reflect.ClassTag<A> t)	Receive next n events/snapshots that have been persisted in the storage.
java.lang.Object	reprToAny(U repr)

Method Detail

expectNextPersisted

<A> A expectNextPersisted(java.lang.String persistenceId,
                          A event)

Check that next persisted in storage for particular persistence id event/snapshot was event.

expectNextPersisted

<A> A expectNextPersisted(java.lang.String persistenceId,
                          A event,
                          scala.concurrent.duration.FiniteDuration max)

Check for max time that next persisted in storage for particular persistence id event/snapshot was event.

expectNextPersistedClass

<A> A expectNextPersistedClass(java.lang.String persistenceId,
                               java.lang.Class<A> cla)

Check that next persisted in storage for particular persistence id event/snapshot has expected type.

expectNextPersistedClass

<A> A expectNextPersistedClass(java.lang.String persistenceId,
                               java.lang.Class<A> cla,
                               scala.concurrent.duration.FiniteDuration max)

Check for max time that next persisted in storage for particular persistence id event/snapshot has expected type.

expectNextPersistedType

<A> A expectNextPersistedType(java.lang.String persistenceId,
                              scala.reflect.ClassTag<A> t)

Check that next persisted in storage for particular persistence id event/snapshot has expected type.

expectNextPersistedType

<A> A expectNextPersistedType(java.lang.String persistenceId,
                              scala.concurrent.duration.FiniteDuration max,
                              scala.reflect.ClassTag<A> t)

Check for max time that next persisted in storage for particular persistence id event/snapshot has expected type.

expectNothingPersisted

void expectNothingPersisted(java.lang.String persistenceId)

Check that nothing was persisted in storage for particular persistence id.

expectNothingPersisted

void expectNothingPersisted(java.lang.String persistenceId,
                            scala.concurrent.duration.FiniteDuration max)

Check for max time that nothing was persisted in storage for particular persistence id.

getItem

scala.Option<java.lang.Object> getItem(java.lang.String persistenceId,
                                       int nextInd)

maxTimeout

scala.concurrent.duration.FiniteDuration maxTimeout()

pollInterval

scala.concurrent.duration.FiniteDuration pollInterval()

probe

TestKitBase probe()

receivePersisted

<A> scala.collection.immutable.Seq<A> receivePersisted(java.lang.String persistenceId,
                                                       int n,
                                                       scala.concurrent.duration.FiniteDuration max,
                                                       scala.reflect.ClassTag<A> t)

Receive for max time next n events/snapshots that have been persisted in the storage.

receivePersisted

<A> scala.collection.immutable.Seq<A> receivePersisted(java.lang.String persistenceId,
                                                       int n,
                                                       scala.reflect.ClassTag<A> t)

Receive next n events/snapshots that have been persisted in the storage.

receivePersisted

<A> scala.collection.immutable.Seq<A> receivePersisted(java.lang.String persistenceId,
                                                       int n,
                                                       java.lang.Class<A> cla)

Receive next n events/snapshots that have been persisted in the storage.

receivePersisted

<A> scala.collection.immutable.Seq<A> receivePersisted(java.lang.String persistenceId,
                                                       int n,
                                                       java.lang.Class<A> cla,
                                                       scala.concurrent.duration.FiniteDuration max)

Receive for max time next n events/snapshots that have been persisted in the storage.

reprToAny

java.lang.Object reprToAny(U repr)