Update PersistenceQueryDocSpec.scala (#24405)
This commit is contained in:
parent
538a5a4ae6
commit
1a63aa8637
1 changed files with 1 additions and 1 deletions
|
|
@ -238,7 +238,7 @@ class PersistenceQueryDocSpec(s: String) extends AkkaSpec(s) {
|
|||
// assuming journal is able to work with numeric offsets we can:
|
||||
|
||||
val blueThings: Source[EventEnvelope, NotUsed] =
|
||||
readJournal.eventsByTag("blue")
|
||||
readJournal.eventsByTag("blue", Offset.noOffset)
|
||||
|
||||
// find top 10 blue things:
|
||||
val top10BlueThings: Future[Vector[Any]] =
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue