This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-dynamodb.git
The following commit(s) were added to refs/heads/main by this push:
new d9c45cb pekko 1.3.0 (#248)
d9c45cb is described below
commit d9c45cb6cc159836c80d0980c7b4f6d876c079e0
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Nov 26 11:50:28 2025 +0100
pekko 1.3.0 (#248)
---
project/PekkoCoreDependency.scala | 2 +-
.../dynamodb/journal/DynamoPartitionGroupedSpec.scala | 10 +++++-----
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/project/PekkoCoreDependency.scala
b/project/PekkoCoreDependency.scala
index 992921f..61d5bd7 100644
--- a/project/PekkoCoreDependency.scala
+++ b/project/PekkoCoreDependency.scala
@@ -20,5 +20,5 @@ import com.github.pjfanning.pekkobuild.PekkoDependency
object PekkoCoreDependency extends PekkoDependency {
override val checkProject: String = "pekko-cluster-sharding-typed"
override val module: Option[String] = None
- override val currentVersion: String = "1.1.5"
+ override val currentVersion: String = "1.3.0"
}
diff --git
a/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoPartitionGroupedSpec.scala
b/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoPartitionGroupedSpec.scala
index ac7e394..64c9076 100644
---
a/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoPartitionGroupedSpec.scala
+++
b/src/test/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoPartitionGroupedSpec.scala
@@ -27,7 +27,7 @@ class DynamoPartitionGroupedSpec extends
TestKit(ActorSystem("DynamoPartitionGro
Source(1L to 250).via(DynamoPartitionGrouped)
sourceUnderTest
- .runWith(TestSink.probe[PartitionKeys])
+ .runWith(TestSink[PartitionKeys]())
.request(1)
.expectNext(PartitionKeys(0L, 1L to 99))
.request(1)
@@ -42,7 +42,7 @@ class DynamoPartitionGroupedSpec extends
TestKit(ActorSystem("DynamoPartitionGro
Source(85L to 300).via(DynamoPartitionGrouped)
sourceUnderTest
- .runWith(TestSink.probe[PartitionKeys])
+ .runWith(TestSink[PartitionKeys]())
.request(1)
.expectNext(PartitionKeys(0L, 85L to 99))
.request(1)
@@ -59,7 +59,7 @@ class DynamoPartitionGroupedSpec extends
TestKit(ActorSystem("DynamoPartitionGro
Source(185L to 512).via(DynamoPartitionGrouped)
sourceUnderTest
- .runWith(TestSink.probe[PartitionKeys])
+ .runWith(TestSink[PartitionKeys]())
.request(1)
.expectNext(PartitionKeys(1L, 185L to 199))
.request(3)
@@ -76,7 +76,7 @@ class DynamoPartitionGroupedSpec extends
TestKit(ActorSystem("DynamoPartitionGro
Source(1L to 15).via(DynamoPartitionGrouped)
sourceUnderTest
- .runWith(TestSink.probe[PartitionKeys])
+ .runWith(TestSink[PartitionKeys]())
.request(2)
.expectNext(PartitionKeys(0L, 1L to 15))
.expectComplete()
@@ -87,7 +87,7 @@ class DynamoPartitionGroupedSpec extends
TestKit(ActorSystem("DynamoPartitionGro
Source(1L to 99).via(DynamoPartitionGrouped)
sourceUnderTest
- .runWith(TestSink.probe[PartitionKeys])
+ .runWith(TestSink[PartitionKeys]())
.request(2)
.expectNext(PartitionKeys(0L, 1L to 99))
.expectComplete()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
