Package org.apache.pekko.persistence.query.typed.javadsl

Interface CurrentEventsByPersistenceIdTypedQuery

All Superinterfaces:
ReadJournal
All Known Implementing Classes:
PersistenceTestKitReadJournal
public interface CurrentEventsByPersistenceIdTypedQuery extends ReadJournal
A plugin may optionally support this query by implementing this trait.

API May Change

  • Method Summary

    Modifier and Type
    Method
    Description
    <Event> Source<EventEnvelope<Event>,NotUsed>
    currentEventsByPersistenceIdTyped(String persistenceId, long fromSequenceNr, long toSequenceNr)
    Same as EventsByPersistenceIdTypedQuery.eventsByPersistenceIdTyped but the stream is completed immediately when it reaches the end of the "current" events.

  • Method Details

    • currentEventsByPersistenceIdTyped

      <Event> Source<EventEnvelope<Event>,NotUsed> currentEventsByPersistenceIdTyped(String persistenceId, long fromSequenceNr, long toSequenceNr)
      Same as EventsByPersistenceIdTypedQuery.eventsByPersistenceIdTyped but the stream is completed immediately when it reaches the end of the "current" events. Events that are stored after the query is started are not included in the stream.