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". Events that are stored after the query is completed are not included in the event stream.
-
-
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)
-
-