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-persistence-r2dbc.git
The following commit(s) were added to refs/heads/main by this push:
new ce90b6e pekko 1.3.0 (#268)
ce90b6e is described below
commit ce90b6eb16d6f16f75a164669fe94b14bdace953
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Nov 24 14:34:13 2025 +0100
pekko 1.3.0 (#268)
---
.../pekko/persistence/r2dbc/internal/ContinuousQuerySpec.scala | 6 +++---
.../persistence/r2dbc/query/EventsBySliceBacktrackingSpec.scala | 2 +-
.../pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala | 2 +-
.../apache/pekko/persistence/r2dbc/query/EventsBySliceSpec.scala | 4 ++--
project/PekkoCoreDependency.scala | 2 +-
.../org/apache/pekko/projection/r2dbc/R2dbcProjectionSpec.scala | 4 ++--
6 files changed, 10 insertions(+), 10 deletions(-)
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/internal/ContinuousQuerySpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/internal/ContinuousQuerySpec.scala
index cbbaa39..3962938 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/internal/ContinuousQuerySpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/internal/ContinuousQuerySpec.scala
@@ -89,7 +89,7 @@ class ContinuousQuerySpec extends ScalaTestWithActorTestKit
with AnyWordSpecLike
updateState = (state, _) => state.copy(value = "cats"),
delayNextQuery = state => Some(1.second),
nextQuery = state => state -> results.next())
- .runWith(TestSink.probe[String])
+ .runWith(TestSink[String]())
sub
.request(1)
@@ -113,7 +113,7 @@ class ContinuousQuerySpec extends ScalaTestWithActorTestKit
with AnyWordSpecLike
delayNextQuery = state => Some(1.second),
nextQuery = state => state -> results.next())
.map(_.apply())
- .runWith(TestSink.probe)
+ .runWith(TestSink())
sub
.requestNext("one")
@@ -131,7 +131,7 @@ class ContinuousQuerySpec extends ScalaTestWithActorTestKit
with AnyWordSpecLike
updateState = (state, _) => state.copy(value = "cats"),
delayNextQuery = state => Some(1.second),
nextQuery = state => state -> results.next())
- .runWith(TestSink.probe[String])
+ .runWith(TestSink[String]())
// give time for the startup to do the pull the buffer the element
Thread.sleep(500)
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySliceBacktrackingSpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySliceBacktrackingSpec.scala
index 385252e..b32d13c 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySliceBacktrackingSpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySliceBacktrackingSpec.scala
@@ -85,7 +85,7 @@ class EventsBySliceBacktrackingSpec
val pid2 = nextPid(entityType)
val slice1 = query.sliceForPersistenceId(pid1)
val slice2 = query.sliceForPersistenceId(pid2)
- val sinkProbe =
TestSink.probe[EventEnvelope[String]](system.classicSystem)
+ val sinkProbe = TestSink[EventEnvelope[String]]()(system.classicSystem)
// don't let behind-current-time be a reason for not finding events
val startTime = Instant.now().minusSeconds(10 * 60)
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
index 125a2f8..47e7f4a 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
@@ -75,7 +75,7 @@ class EventsBySlicePubSubSpec
val slice = query.sliceForPersistenceId(persistenceId)
val persister = spawn(TestActors.Persister(persistenceId))
val probe = createTestProbe[Done]()
- val sinkProbe = TestSink.probe[EventEnvelope[String]](system.classicSystem)
+ val sinkProbe = TestSink[EventEnvelope[String]]()(system.classicSystem)
}
private def createEnvelope(pid: PersistenceId, seqNr: Long, evt: String):
EventEnvelope[String] = {
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySliceSpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySliceSpec.scala
index 6d52110..05a6d11 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySliceSpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySliceSpec.scala
@@ -91,7 +91,7 @@ class EventsBySliceSpec
val slice = query.sliceForPersistenceId(persistenceId)
val persister = spawn(TestActors.Persister(persistenceId))
val probe = createTestProbe[Done]()
- val sinkProbe = TestSink.probe[EventEnvelope[String]](system.classicSystem)
+ val sinkProbe = TestSink[EventEnvelope[String]]()(system.classicSystem)
}
List[QueryType](Current, Live).foreach { queryType =>
@@ -151,7 +151,7 @@ class EventsBySliceSpec
val withOffset =
doQuery(entityType, slice, slice, offset)
-
.runWith(TestSink.probe[EventEnvelope[String]](system.classicSystem))
+ .runWith(TestSink[EventEnvelope[String]]()(system.classicSystem))
withOffset.request(12)
for (i <- 11 to 20) {
withOffset.expectNext().event shouldBe s"e-$i"
diff --git a/project/PekkoCoreDependency.scala
b/project/PekkoCoreDependency.scala
index 1ad1bac..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.2.1"
+ override val currentVersion: String = "1.3.0"
}
diff --git
a/projection/src/test/scala/org/apache/pekko/projection/r2dbc/R2dbcProjectionSpec.scala
b/projection/src/test/scala/org/apache/pekko/projection/r2dbc/R2dbcProjectionSpec.scala
index c6868f3..04710c5 100644
---
a/projection/src/test/scala/org/apache/pekko/projection/r2dbc/R2dbcProjectionSpec.scala
+++
b/projection/src/test/scala/org/apache/pekko/projection/r2dbc/R2dbcProjectionSpec.scala
@@ -831,7 +831,7 @@ class R2dbcProjectionSpec
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
}
@@ -876,7 +876,7 @@ class R2dbcProjectionSpec
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
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
