raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

fix Fix JournalSpec: swap AtomicWrite(Seq) with Seq(AtomicWrite)

Browse source
This commit is contained in:
Yaroslav Klymko 2015-08-31 08:01:27 +03:00
parent 3d4b5f57b0
commit a00ae5006c
1 changed files with 13 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

26
akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala
View file

@ -56,24 +56,24 @@ abstract class JournalSpec(config: Config) extends PluginSpec(config) {
ReplayedMessage(PersistentImpl(s"a-${snr}", snr, pid, "", deleted, Actor.noSender, writerUuid))
def writeMessages(fromSnr: Int, toSnr: Int, pid: String, sender: ActorRef, writerUuid: String): Unit = {
def persistentRepr(sequenceNr: Long) = PersistentRepr(
payload = s"a-$sequenceNr", sequenceNr = sequenceNr, persistenceId = pid,
sender = sender, writerUuid = writerUuid)
val msgs =
if (supportsAtomicPersistAllOfSeveralEvents)
(fromSnr to toSnr).map { i ⇒
AtomicWrite(PersistentRepr(payload = s"a-$i", sequenceNr = i, persistenceId = pid, sender = sender,
writerUuid = writerUuid))
}
else
if (supportsAtomicPersistAllOfSeveralEvents) {
(fromSnr to toSnr - 1).map { i ⇒
if (i == toSnr - 1)
AtomicWrite(List(
PersistentRepr(payload = s"a-$i", sequenceNr = i, persistenceId = pid, sender = sender,
writerUuid = writerUuid),
PersistentRepr(payload = s"a-${i + 1}", sequenceNr = i + 1, persistenceId = pid, sender = sender,
writerUuid = writerUuid)))
AtomicWrite(List(persistentRepr(i), persistentRepr(i + 1)))
else
AtomicWrite(PersistentRepr(payload = s"a-${i}", sequenceNr = i, persistenceId = pid, sender = sender,
writerUuid = writerUuid))
AtomicWrite(persistentRepr(i))
}
} else {
(fromSnr to toSnr).map { i ⇒
AtomicWrite(PersistentRepr(persistentRepr(i)))
}
}
val probe = TestProbe()