Package akka.persistence.query.scaladsl
Interface CurrentEventsByTagQuery
-
- All Superinterfaces:
ReadJournal
- All Known Implementing Classes:
LeveldbReadJournal
public interface CurrentEventsByTagQuery extends ReadJournal
Same type of query asEventsByTagQuery.eventsByTag(java.lang.String, akka.persistence.query.Offset)
but the event stream is completed immediately when it reaches the end of the "result set". Depending on journal implementation, this may mean all events up to when the query is started, or it may include events that are persisted while the query is still streaming results. For eventually consistent stores, it may only include all events up to some point before the query is started.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Source<EventEnvelope,NotUsed>
currentEventsByTag(java.lang.String tag, Offset offset)
-
-
-
Method Detail
-
currentEventsByTag
Source<EventEnvelope,NotUsed> currentEventsByTag(java.lang.String tag, Offset offset)
-
-