Package akka.persistence.query.typed.scaladsl

Interface EventsByPersistenceIdStartingFromSnapshotQuery

All Superinterfaces:

ReadJournal

public interface EventsByPersistenceIdStartingFromSnapshotQuery
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>	eventsByPersistenceIdStartingFromSnapshot(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, scala.Function1<Snapshot,Event> transformSnapshot)	Same as EventsByPersistenceIdTypedQuery but with the purpose to use snapshot as starting point and thereby reducing number of events that have to be loaded.

Method Detail

eventsByPersistenceIdStartingFromSnapshot

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

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