This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch 1.2.x
in repository https://gitbox.apache.org/repos/asf/pekko-projection.git
The following commit(s) were added to refs/heads/1.2.x by this push:
new 460b82c pekko 1.3.0 (#348) (#351)
460b82c is described below
commit 460b82c224c9d9fd273bb9dfe993458cf6a68080
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Nov 26 11:51:18 2025 +0100
pekko 1.3.0 (#348) (#351)
revert pekko
---
.../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 ++--
.../scala/org/apache/pekko/projection/slick/SlickProjectionSpec.scala | 4 ++--
.../apache/pekko/projection/testkit/scaladsl/ProjectionTestKit.scala | 2 +-
7 files changed, 12 insertions(+), 12 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 5960086..23234e7 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 ce462fa..565f474 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
@@ -123,7 +123,7 @@ class EventSourcedProviderSpec
.source(() => Future.successful(Some(NoOffset)))
.futureValue
.map(_.event)
- .runWith(TestSink.probe)
+ .runWith(TestSink())
.request(expectedEvents.size)
.expectNextN(expectedEvents)
.request(1)
@@ -155,7 +155,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 9105816..a87ba11 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/slick/src/test/scala/org/apache/pekko/projection/slick/SlickProjectionSpec.scala
b/slick/src/test/scala/org/apache/pekko/projection/slick/SlickProjectionSpec.scala
index 2c84bf7..a1298e9 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]
