This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-persistence-dynamodb.git
The following commit(s) were added to refs/heads/main by this push:
new 4f60865 Unwrap single string interpolation syntax
4f60865 is described below
commit 4f608652ffa2765b3b854653971f03f854d6017d
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sat May 27 13:34:21 2023 +0200
Unwrap single string interpolation syntax
---
project/CopyrightHeader.scala | 2 +-
.../journal/DynamoDBIntegrationLoadSpec.scala | 38 +++++++++++-----------
.../journal/PersistAllConsistencySpec.scala | 8 ++---
3 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/project/CopyrightHeader.scala b/project/CopyrightHeader.scala
index ca3fd39..400bc96 100644
--- a/project/CopyrightHeader.scala
+++ b/project/CopyrightHeader.scala
@@ -67,7 +67,7 @@ trait CopyrightHeader extends AutoPlugin {
case Some(currentText) if isLightbendCopyrighted(currentText) =>
HeaderCommentStyle.cStyleBlockComment.commentCreator(text,
existingText) + NewLine * 2 + currentText
case Some(currentText) =>
- throw new IllegalStateException(s"Unable to detect copyright for
header:[${currentText}]")
+ throw new IllegalStateException(s"Unable to detect copyright for
header:[$currentText]")
case None =>
HeaderCommentStyle.cStyleBlockComment.commentCreator(text,
existingText)
}
diff --git
a/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBIntegrationLoadSpec.scala
b/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBIntegrationLoadSpec.scala
index 8a0b1b8..b38bb76 100644
---
a/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBIntegrationLoadSpec.scala
+++
b/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBIntegrationLoadSpec.scala
@@ -89,7 +89,7 @@ pekko.persistence.snapshot-store.plugin = ""
def receiveRecover: Receive = {
case SnapshotOffer(_, snapshot: String) =>
last = snapshot
- probe ! s"offered-${last}"
+ probe ! s"offered-$last"
case payload: String =>
handle(payload)
}
@@ -98,7 +98,7 @@ pekko.persistence.snapshot-store.plugin = ""
case "snap" =>
saveSnapshot(last)
case SaveSnapshotSuccess(_) =>
- probe ! s"snapped-${last}"
+ probe ! s"snapped-$last"
case payload: String =>
persist(payload)(handle)
case DeleteTo(sequenceNr) =>
@@ -160,8 +160,8 @@ class DynamoDBIntegrationLoadSpec
val processor1 = system.actorOf(Props(classOf[ProcessorA], persistenceId,
self))
(1L to 16L).foreach { i =>
- processor1 ! s"a-${i}"
- expectMsgAllOf(s"a-${i}", i, false)
+ processor1 ! s"a-$i"
+ expectMsgAllOf(s"a-$i", i, false)
}
processor1 ! DeleteTo(3L)
@@ -169,7 +169,7 @@ class DynamoDBIntegrationLoadSpec
system.actorOf(Props(classOf[ProcessorA], persistenceId, self))
(4L to 16L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, true)
+ expectMsgAllOf(s"a-$i", i, true)
}
processor1 ! DeleteTo(7L)
@@ -177,7 +177,7 @@ class DynamoDBIntegrationLoadSpec
system.actorOf(Props(classOf[ProcessorA], persistenceId, self))
(8L to 16L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, true)
+ expectMsgAllOf(s"a-$i", i, true)
}
}
@@ -187,13 +187,13 @@ class DynamoDBIntegrationLoadSpec
val persistenceId = UUID.randomUUID().toString
val processor1 = system.actorOf(Props(classOf[ProcessorA],
persistenceId, self), "p1")
(1L to 16L).foreach { i =>
- processor1 ! s"a-${i}"
- expectMsgAllOf(s"a-${i}", i, false)
+ processor1 ! s"a-$i"
+ expectMsgAllOf(s"a-$i", i, false)
}
val processor2 = system.actorOf(Props(classOf[ProcessorA],
persistenceId, self), "p2")
(1L to 16L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, true)
+ expectMsgAllOf(s"a-$i", i, true)
}
processor2 ! "b"
@@ -210,8 +210,8 @@ class DynamoDBIntegrationLoadSpec
val probe = TestProbe()
val processor1 = system.actorOf(Props(classOf[ProcessorA],
persistenceId, self))
1L to 6L foreach { i =>
- processor1 ! s"a-${i}"
- expectMsgAllOf(s"a-${i}", i, false)
+ processor1 ! s"a-$i"
+ expectMsgAllOf(s"a-$i", i, false)
}
val view = system.actorOf(Props(classOf[ViewA], "p7-view",
persistenceId, probe.ref))
@@ -236,13 +236,13 @@ class DynamoDBIntegrationLoadSpec
processorAtomic ! List("a-1", "a-2", "a-3", "a-4", "a-5", "a-6")
(1L to 6L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, false)
+ expectMsgAllOf(s"a-$i", i, false)
}
val testProbe = TestProbe()
val processor2 = system.actorOf(Props(classOf[ProcessorAtomic],
persistenceId, testProbe.ref))
(1L to 6L).foreach { i =>
- testProbe.expectMsgAllOf(s"a-${i}", i, true)
+ testProbe.expectMsgAllOf(s"a-$i", i, true)
}
}
"write and replay with persistAll greater than partition size skipping
part of a partition" in {
@@ -252,18 +252,18 @@ class DynamoDBIntegrationLoadSpec
processorAtomic ! List("a-1", "a-2", "a-3")
(1L to 3L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, false)
+ expectMsgAllOf(s"a-$i", i, false)
}
processorAtomic ! List("a-4", "a-5", "a-6")
(4L to 6L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, false)
+ expectMsgAllOf(s"a-$i", i, false)
}
val testProbe = TestProbe()
val processor2 = system.actorOf(Props(classOf[ProcessorAtomic],
persistenceId, testProbe.ref))
(1L to 6L).foreach { i =>
- testProbe.expectMsgAllOf(s"a-${i}", i, true)
+ testProbe.expectMsgAllOf(s"a-$i", i, true)
}
}
"write and replay with persistAll less than partition size" in {
@@ -273,12 +273,12 @@ class DynamoDBIntegrationLoadSpec
processorAtomic ! List("a-1", "a-2", "a-3", "a-4")
(1L to 4L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, false)
+ expectMsgAllOf(s"a-$i", i, false)
}
val processor2 = system.actorOf(Props(classOf[ProcessorAtomic],
persistenceId, self))
(1L to 4L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, true)
+ expectMsgAllOf(s"a-$i", i, true)
}
}
"not replay messages deleted from the +1 partition" in {
@@ -290,7 +290,7 @@ class DynamoDBIntegrationLoadSpec
List("a-1", "a-2", "a-3", "a-4", "a-5", "a-6").foreach(processorAtomic !
List(_))
(1L to 6L).foreach { i =>
- expectMsgAllOf(s"a-${i}", i, false)
+ expectMsgAllOf(s"a-$i", i, false)
}
processorAtomic ! DeleteTo(5L)
awaitRangeDeletion(deleteProbe)
diff --git
a/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/PersistAllConsistencySpec.scala
b/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/PersistAllConsistencySpec.scala
index b2cdced..aa9a1a0 100644
---
a/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/PersistAllConsistencySpec.scala
+++
b/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/PersistAllConsistencySpec.scala
@@ -57,7 +57,7 @@ class PersistAllConsistencySpec
val start = nextSeqNr
val end = 10
- println(s"start: ${start}; end: ${end}")
+ println(s"start: $start; end: $end")
val padding = AtomicWrite((start to end).map(i =>
persistentRepr(f"h-$i"))) :: Nil
journal ! WriteMessages(padding, testActor, 1)
@@ -73,7 +73,7 @@ class PersistAllConsistencySpec
s"correctly cross page boundaries with AtomicWrite position ${t._1}" in {
val start1 = nextSeqNr
val end1 = ((start1 / PartitionSize) + 1) * PartitionSize - t._2
- println(s"start: ${start1}; end: ${end1}")
+ println(s"start: $start1; end: $end1")
val padding = AtomicWrite((start1 to end1).map(i =>
persistentRepr(f"h-$i"))) :: Nil
journal ! WriteMessages(padding, testActor, 1)
@@ -82,7 +82,7 @@ class PersistAllConsistencySpec
val start2 = nextSeqNr
val end2 = start2 + 2
- println(s"start: ${start2}; end: ${end2}")
+ println(s"start: $start2; end: $end2")
val subject = AtomicWrite((start2 to end2).map(i =>
persistentRepr(f"h-$i"))) :: Nil
journal ! WriteMessages(subject, testActor, 1)
@@ -97,7 +97,7 @@ class PersistAllConsistencySpec
s"recover correctly when the last partition event ends on ${PartitionSize
- 1}" in {
val start = nextSeqNr
val end = ((start / PartitionSize) + 1) * PartitionSize - 1
- println(s"start: ${start}; end: ${end}")
+ println(s"start: $start; end: $end")
val padding = AtomicWrite((start to end).map(i =>
persistentRepr(f"h-$i"))) :: Nil
journal ! WriteMessages(padding, testActor, 1)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
