Package akka.persistence.query.typed.scaladsl

Interface CurrentEventsByPersistenceIdStartingFromSnapshotQuery

All Superinterfaces:

ReadJournal

public interface CurrentEventsByPersistenceIdStartingFromSnapshotQuery
extends ReadJournal

A plugin may optionally support this query by implementing this trait.

Method Summary

Modifier and Type	Method	Description
<Snapshot,Event> Source<EventEnvelope<Event>,NotUsed>	currentEventsByPersistenceIdStartingFromSnapshot(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, scala.Function1<Snapshot,Event> transformSnapshot)	Same as CurrentEventsByPersistenceIdTypedQuery but with the purpose to use snapshot as starting point and thereby reducing number of events that have to be loaded.

Method Detail

currentEventsByPersistenceIdStartingFromSnapshot

<Snapshot,Event> Source<EventEnvelope<Event>,NotUsed> currentEventsByPersistenceIdStartingFromSnapshot(java.lang.String persistenceId,
                                                                                                                   long fromSequenceNr,
                                                                                                                   long toSequenceNr,
                                                                                                                   scala.Function1<Snapshot,Event> transformSnapshot)

Same as CurrentEventsByPersistenceIdTypedQuery but with the purpose to use snapshot as starting point and thereby reducing number of events that have to be loaded.