akka/akka-core

add persistence query methods that start “now”

Open

#19,328 opened on Jan 2, 2016

View on GitHub
 (7 comments) (0 reactions) (0 assignees)Scala (3,547 forks)batch import
1 - triagedhelp wantedt:persistence-query

Repository metrics

Stars
 (13,277 stars)
PR merge metrics
 (Avg merge 8d 19h) (10 merged PRs in 30d)

Description

For cases where the client is interested in live data we’d need to either provide a way to obtain the current offset and start from there, or we allow the specification of “now” as a starting offset for the query directly—the latter could be done by using Long.MaxValue as a special value.

Contributor guide