Package org.apache.pekko.persistence.testkit.scaladsl

Interface PersistenceProbe<T>

public interface PersistenceProbe<T>
Not for user extension

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.collection.immutable.Seq<PersistenceEffect<T>>
    drain()
    Collect all persistence effects from the probe and empty the probe
    PersistenceProbe<T>
    expectPersisted(T obj)
    Assert that the given object was persisted in the oldest persistence effect and remove that persistence effect
    PersistenceProbe<T>
    expectPersisted(T obj, String tag)
    Assert that the given object was persisted with the given tag in the oldest persistence effect and remove that persistence effect.
    PersistenceProbe<T>
    expectPersisted(T obj, scala.collection.immutable.Set<String> tags)
    Assert that the given object was persisted with the given tags in the oldest persistence effect and remove that persistence effect.
    <S extends T>
    PersistenceEffect<S>
    expectPersistedType(scala.reflect.ClassTag<S> evidence$1)
    Get and remove the oldest persistence effect from the probe, failing if the persisted object is not of the requested type
    PersistenceEffect<T>
    extract()
    Get and remove the oldest persistence effect from the probe
    boolean
    hasEffects()
    Are there any persistence effects?

  • Method Details

    • drain

      scala.collection.immutable.Seq<PersistenceEffect<T>> drain()
      Collect all persistence effects from the probe and empty the probe

    • expectPersisted

      PersistenceProbe<T> expectPersisted(T obj)
      Assert that the given object was persisted in the oldest persistence effect and remove that persistence effect

    • expectPersisted

      PersistenceProbe<T> expectPersisted(T obj, String tag)
      Assert that the given object was persisted with the given tag in the oldest persistence effect and remove that persistence effect. If the persistence effect has multiple tags, only one of them has to match in order for the assertion to succeed.

    • expectPersisted

      PersistenceProbe<T> expectPersisted(T obj, scala.collection.immutable.Set<String> tags)
      Assert that the given object was persisted with the given tags in the oldest persistence effect and remove that persistence effect. If the persistence effect has tags which are not given, the assertion fails.

    • expectPersistedType

      <S extends T> PersistenceEffect<S> expectPersistedType(scala.reflect.ClassTag<S> evidence$1)
      Get and remove the oldest persistence effect from the probe, failing if the persisted object is not of the requested type

    • extract

      PersistenceEffect<T> extract()
      Get and remove the oldest persistence effect from the probe

    • hasEffects

      boolean hasEffects()
      Are there any persistence effects?