This is an automated email from the ASF dual-hosted git repository.
engelen pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-projection.git
The following commit(s) were added to refs/heads/main by this push:
new abd0f5f pekko 1.3.0 (#348)
abd0f5f is described below
commit abd0f5f972d6e0a1a688e88e1c713ee1e5e46e16
Author: PJ Fanning <[email protected]>
AuthorDate: Tue Nov 25 10:07:00 2025 +0100
pekko 1.3.0 (#348)
---
.../apache/pekko/projection/cassandra/CassandraProjectionSpec.scala | 4 ++--
.../projection/eventsourced/scaldsl/EventSourcedProviderSpec.scala | 4 ++--
.../scala/org/apache/pekko/projection/jdbc/JdbcProjectionSpec.scala | 4 ++--
.../java/org/apache/pekko/projection/jdbc/JdbcProjectionTest.java | 2 +-
.../org/apache/pekko/projection/kafka/KafkaSourceProviderSpec.scala | 4 ++--
project/PekkoConnectorsDependency.scala | 2 +-
project/PekkoCoreDependency.scala | 2 +-
.../scala/org/apache/pekko/projection/slick/SlickProjectionSpec.scala | 4 ++--
.../apache/pekko/projection/testkit/scaladsl/ProjectionTestKit.scala | 2 +-
9 files changed, 14 insertions(+), 14 deletions(-)
diff --git
a/cassandra-test/src/test/scala/org/apache/pekko/projection/cassandra/CassandraProjectionSpec.scala
b/cassandra-test/src/test/scala/org/apache/pekko/projection/cassandra/CassandraProjectionSpec.scala
index e7d36d6..277828b 100644
---
a/cassandra-test/src/test/scala/org/apache/pekko/projection/cassandra/CassandraProjectionSpec.scala
+++
b/cassandra-test/src/test/scala/org/apache/pekko/projection/cassandra/CassandraProjectionSpec.scala
@@ -348,7 +348,7 @@ class CassandraProjectionSpec
import pekko.actor.typed.scaladsl.adapter._
val sourceProbe = new AtomicReference[TestPublisher.Probe[Envelope]]()
- val source =
TestSource.probe[Envelope](system.toClassic).mapMaterializedValue { probe =>
+ val source =
TestSource[Envelope]()(system.toClassic).mapMaterializedValue { probe =>
sourceProbe.set(probe)
NotUsed
}
@@ -388,7 +388,7 @@ class CassandraProjectionSpec
import pekko.actor.typed.scaladsl.adapter._
val sourceProbe = new AtomicReference[TestPublisher.Probe[Envelope]]()
- val source =
TestSource.probe[Envelope](system.toClassic).mapMaterializedValue { probe =>
+ val source =
TestSource[Envelope]()(system.toClassic).mapMaterializedValue { probe =>
sourceProbe.set(probe)
NotUsed
}
diff --git
a/eventsourced/src/test/scala/org/apache/pekko/projection/eventsourced/scaldsl/EventSourcedProviderSpec.scala
b/eventsourced/src/test/scala/org/apache/pekko/projection/eventsourced/scaldsl/EventSourcedProviderSpec.scala
index 2d4e4fb..6ee4111 100644
---
a/eventsourced/src/test/scala/org/apache/pekko/projection/eventsourced/scaldsl/EventSourcedProviderSpec.scala
+++
b/eventsourced/src/test/scala/org/apache/pekko/projection/eventsourced/scaldsl/EventSourcedProviderSpec.scala
@@ -124,7 +124,7 @@ class EventSourcedProviderSpec
.source(() => Future.successful(Some(NoOffset)))
.futureValue
.map(_.event)
- .runWith(TestSink.probe)
+ .runWith(TestSink())
.request(expectedEvents.size)
.expectNextN(expectedEvents)
.request(1)
@@ -156,7 +156,7 @@ class EventSourcedProviderSpec
.source(() => Future.successful(Some(NoOffset)))
.futureValue
.map(_.event)
- .runWith(TestSink.probe)
+ .runWith(TestSink())
.request(expectedEvents.size)
.expectNextN(expectedEvents)
.request(1)
diff --git
a/jdbc-int-test/src/test/scala/org/apache/pekko/projection/jdbc/JdbcProjectionSpec.scala
b/jdbc-int-test/src/test/scala/org/apache/pekko/projection/jdbc/JdbcProjectionSpec.scala
index 7226b53..7d7bc52 100644
---
a/jdbc-int-test/src/test/scala/org/apache/pekko/projection/jdbc/JdbcProjectionSpec.scala
+++
b/jdbc-int-test/src/test/scala/org/apache/pekko/projection/jdbc/JdbcProjectionSpec.scala
@@ -843,7 +843,7 @@ class JdbcProjectionSpec
import pekko.actor.typed.scaladsl.adapter._
val sourceProbe = new AtomicReference[TestPublisher.Probe[Envelope]]()
- val source =
TestSource.probe[Envelope](system.toClassic).mapMaterializedValue { probe =>
+ val source =
TestSource[Envelope]()(system.toClassic).mapMaterializedValue { probe =>
sourceProbe.set(probe)
NotUsed
}
@@ -887,7 +887,7 @@ class JdbcProjectionSpec
import pekko.actor.typed.scaladsl.adapter._
val sourceProbe = new AtomicReference[TestPublisher.Probe[Envelope]]()
- val source =
TestSource.probe[Envelope](system.toClassic).mapMaterializedValue { probe =>
+ val source =
TestSource[Envelope]()(system.toClassic).mapMaterializedValue { probe =>
sourceProbe.set(probe)
NotUsed
}
diff --git
a/jdbc/src/test/java/org/apache/pekko/projection/jdbc/JdbcProjectionTest.java
b/jdbc/src/test/java/org/apache/pekko/projection/jdbc/JdbcProjectionTest.java
index d7ed26d..020c785 100644
---
a/jdbc/src/test/java/org/apache/pekko/projection/jdbc/JdbcProjectionTest.java
+++
b/jdbc/src/test/java/org/apache/pekko/projection/jdbc/JdbcProjectionTest.java
@@ -347,7 +347,7 @@ public class JdbcProjectionTest extends JUnitSuite {
(probe) -> {
/*
* We only want to process 3 elements through the handler, but given
buffering within the projections
- * at-least-once impl. we actually process +1 element than we
requested with the TestSink.probe.
+ * at-least-once impl. we actually process +1 element than we
requested with the TestSink().
*
* See https://github.com/akka/akka-projection/issues/462 for a
possible solution.
*/
diff --git
a/kafka-test/src/test/scala/org/apache/pekko/projection/kafka/KafkaSourceProviderSpec.scala
b/kafka-test/src/test/scala/org/apache/pekko/projection/kafka/KafkaSourceProviderSpec.scala
index 0c255ab..52cafb9 100644
---
a/kafka-test/src/test/scala/org/apache/pekko/projection/kafka/KafkaSourceProviderSpec.scala
+++
b/kafka-test/src/test/scala/org/apache/pekko/projection/kafka/KafkaSourceProviderSpec.scala
@@ -41,7 +41,7 @@ class KafkaSourceProviderSpec extends KafkaSpecBase {
Future.successful(Option(MergeableOffset(Map(KafkaOffsets.partitionToKey(topic,
0) -> JLong.valueOf(5L)))))
val probe = Source
.futureSource(provider.source(readOffsetsHandler))
- .runWith(TestSink.probe)
+ .runWith(TestSink())
probe.request(1)
val first = probe.expectNext()
@@ -61,7 +61,7 @@ class KafkaSourceProviderSpec extends KafkaSpecBase {
val readOffsetsHandler = () => Future.successful(None)
val probe = Source
.futureSource(provider.source(readOffsetsHandler))
- .runWith(TestSink.probe)
+ .runWith(TestSink())
probe.request(1)
val first = probe.expectNext()
diff --git a/project/PekkoConnectorsDependency.scala
b/project/PekkoConnectorsDependency.scala
index 884f027..448a962 100644
--- a/project/PekkoConnectorsDependency.scala
+++ b/project/PekkoConnectorsDependency.scala
@@ -21,5 +21,5 @@ import com.github.pjfanning.pekkobuild.PekkoDependency
object PekkoConnectorsDependency extends PekkoDependency {
override val checkProject: String = "pekko-connectors-cassandra"
override val module: Option[String] = Some("connectors")
- override val currentVersion: String = "1.1.0"
+ override val currentVersion: String = "1.2.0"
}
diff --git a/project/PekkoCoreDependency.scala
b/project/PekkoCoreDependency.scala
index 4fe6ae1..d5d0263 100644
--- a/project/PekkoCoreDependency.scala
+++ b/project/PekkoCoreDependency.scala
@@ -21,5 +21,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/slick/src/test/scala/org/apache/pekko/projection/slick/SlickProjectionSpec.scala
b/slick/src/test/scala/org/apache/pekko/projection/slick/SlickProjectionSpec.scala
index d90174d..2a65b21 100644
---
a/slick/src/test/scala/org/apache/pekko/projection/slick/SlickProjectionSpec.scala
+++
b/slick/src/test/scala/org/apache/pekko/projection/slick/SlickProjectionSpec.scala
@@ -989,7 +989,7 @@ class SlickProjectionSpec
import pekko.actor.typed.scaladsl.adapter._
val sourceProbe = new AtomicReference[TestPublisher.Probe[Envelope]]()
- val source =
TestSource.probe[Envelope](system.toClassic).mapMaterializedValue { probe =>
+ val source =
TestSource[Envelope]()(system.toClassic).mapMaterializedValue { probe =>
sourceProbe.set(probe)
NotUsed
}
@@ -1038,7 +1038,7 @@ class SlickProjectionSpec
import pekko.actor.typed.scaladsl.adapter._
val sourceProbe = new AtomicReference[TestPublisher.Probe[Envelope]]()
- val source =
TestSource.probe[Envelope](system.toClassic).mapMaterializedValue { probe =>
+ val source =
TestSource[Envelope]()(system.toClassic).mapMaterializedValue { probe =>
sourceProbe.set(probe)
NotUsed
}
diff --git
a/testkit/src/main/scala/org/apache/pekko/projection/testkit/scaladsl/ProjectionTestKit.scala
b/testkit/src/main/scala/org/apache/pekko/projection/testkit/scaladsl/ProjectionTestKit.scala
index 36f673d..1486f7d 100644
---
a/testkit/src/main/scala/org/apache/pekko/projection/testkit/scaladsl/ProjectionTestKit.scala
+++
b/testkit/src/main/scala/org/apache/pekko/projection/testkit/scaladsl/ProjectionTestKit.scala
@@ -131,7 +131,7 @@ final class ProjectionTestKit private[projection] (system:
ActorSystem[_]) {
def runWithTestSink(projection: Projection[_])(assertFunction:
TestSubscriber.Probe[Done] => Unit): Unit = {
val actorHandler = spawnActorHandler(projection)
implicit val sys: ActorSystem[_] = system
- val sinkProbe =
projection.mappedSource().runWith(TestSink.probe[Done](testKit.system.classicSystem))
+ val sinkProbe =
projection.mappedSource().runWith(TestSink[Done]()(testKit.system.classicSystem))
try {
assertFunction(sinkProbe)
} finally {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
