Package org.apache.pekko.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(String persistenceId, A event)
    Check that next persisted in storage for particular persistence id event/snapshot was event.
    <A> A
    expectNextPersisted(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(String persistenceId, Class<A> cla)
    Check that next persisted in storage for particular persistence id event/snapshot has expected type.
    <A> A
    expectNextPersistedClass(String persistenceId, 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(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(String persistenceId, scala.reflect.ClassTag<A> t)
    Check that next persisted in storage for particular persistence id event/snapshot has expected type.
    void
    expectNothingPersisted(String persistenceId)
    Check that nothing was persisted in storage for particular persistence id.
    void
    expectNothingPersisted(String persistenceId, scala.concurrent.duration.FiniteDuration max)
    Check for max time that nothing was persisted in storage for particular persistence id.
    scala.Option<Object>
    getItem(String persistenceId, int nextInd)
     
    scala.concurrent.duration.FiniteDuration
    maxTimeout()
     
    scala.concurrent.duration.FiniteDuration
    pollInterval()
     
    TestKitBase
    probe()
     
    <A> scala.collection.immutable.Seq<A>
    receivePersisted(String persistenceId, int n, Class<A> cla)
    Receive next n events/snapshots that have been persisted in the storage.
    <A> scala.collection.immutable.Seq<A>
    receivePersisted(String persistenceId, int n, 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(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(String persistenceId, int n, scala.reflect.ClassTag<A> t)
    Receive next n events/snapshots that have been persisted in the storage.
    Object
    reprToAny(U repr)
     

  • Method Details

    • expectNextPersisted

      <A> A expectNextPersisted(String persistenceId, A event)
      Check that next persisted in storage for particular persistence id event/snapshot was event.

    • expectNextPersisted

      <A> A expectNextPersisted(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(String persistenceId, Class<A> cla)
      Check that next persisted in storage for particular persistence id event/snapshot has expected type.

    • expectNextPersistedClass

      <A> A expectNextPersistedClass(String persistenceId, 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(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(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(String persistenceId)
      Check that nothing was persisted in storage for particular persistence id.

    • expectNothingPersisted

      void expectNothingPersisted(String persistenceId, scala.concurrent.duration.FiniteDuration max)
      Check for max time that nothing was persisted in storage for particular persistence id.

    • getItem

      scala.Option<Object> getItem(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(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(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(String persistenceId, int n, Class<A> cla)
      Receive next n events/snapshots that have been persisted in the storage.

    • receivePersisted

      <A> scala.collection.immutable.Seq<A> receivePersisted(String persistenceId, int n, Class<A> cla, scala.concurrent.duration.FiniteDuration max)
      Receive for max time next n events/snapshots that have been persisted in the storage.

    • reprToAny

      Object reprToAny(U repr)