Interface ExpectOps<U>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      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()
      • 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)