This is an automated email from the ASF dual-hosted git repository. hepin pushed a commit to branch removeProb in repository https://gitbox.apache.org/repos/asf/pekko.git
commit 8a65a26c7481b0dac478365fc80786f5adc52551 Author: He-Pin <[email protected]> AuthorDate: Sat Nov 8 02:01:25 2025 +0800 chore: Remove stream testkit's prob methods --- .../scala/org/apache/pekko/stream/testkit/javadsl/TestSink.scala | 7 ------- .../scala/org/apache/pekko/stream/testkit/javadsl/TestSource.scala | 7 ------- .../scala/org/apache/pekko/stream/testkit/scaladsl/TestSink.scala | 6 ------ .../org/apache/pekko/stream/testkit/scaladsl/TestSource.scala | 6 ------ 4 files changed, 26 deletions(-) diff --git a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/javadsl/TestSink.scala b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/javadsl/TestSink.scala index 98dec58882..d6ab2db74c 100644 --- a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/javadsl/TestSink.scala +++ b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/javadsl/TestSink.scala @@ -14,7 +14,6 @@ package org.apache.pekko.stream.testkit.javadsl import org.apache.pekko -import pekko.actor.ActorSystem import pekko.actor.ClassicActorSystemProvider import pekko.stream.javadsl.Sink import pekko.stream.testkit._ @@ -22,12 +21,6 @@ import pekko.stream.testkit._ /** Java API */ object TestSink { - /** - * A Sink that materialized to a [[pekko.stream.testkit.TestSubscriber]]. - */ - @deprecated("Use `TestSink.create` with ClassicActorSystemProvider instead of ActorSystem", "1.3.0") - def probe[T](system: ActorSystem): Sink[T, TestSubscriber.Probe[T]] = create(system) - /** * A Sink that materialized to a [[pekko.stream.testkit.TestSubscriber]]. */ diff --git a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/javadsl/TestSource.scala b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/javadsl/TestSource.scala index 42c151abc7..968c3f3e49 100644 --- a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/javadsl/TestSource.scala +++ b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/javadsl/TestSource.scala @@ -14,7 +14,6 @@ package org.apache.pekko.stream.testkit.javadsl import org.apache.pekko -import pekko.actor.ActorSystem import pekko.actor.ClassicActorSystemProvider import pekko.stream.javadsl.Source import pekko.stream.testkit._ @@ -22,12 +21,6 @@ import pekko.stream.testkit._ /** Java API */ object TestSource { - /** - * A Source that materializes to a [[pekko.stream.testkit.TestPublisher]]. - */ - @deprecated("Use `TestSource.create` with ClassicActorSystemProvider instead of ActorSystem", "1.3.0") - def probe[T](system: ActorSystem): Source[T, TestPublisher.Probe[T]] = create(system) - /** * A Source that materializes to a [[pekko.stream.testkit.TestPublisher]]. */ diff --git a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/scaladsl/TestSink.scala b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/scaladsl/TestSink.scala index 0ddd14d444..9e38a0d183 100644 --- a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/scaladsl/TestSink.scala +++ b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/scaladsl/TestSink.scala @@ -28,12 +28,6 @@ import pekko.stream.testkit.TestSubscriber.Probe */ object TestSink { - /** - * A Sink that materialized to a [[pekko.stream.testkit.TestSubscriber]]. - */ - @deprecated("Use `TestSink.apply` with implicit ClassicActorSystemProvider instead of ActorSystem", "1.3.0") - def probe[T](implicit system: ActorSystem): Sink[T, Probe[T]] = apply() - /** * A Sink that materialized to a [[pekko.stream.testkit.TestSubscriber]]. */ diff --git a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/scaladsl/TestSource.scala b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/scaladsl/TestSource.scala index 2375769a34..371cb53831 100644 --- a/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/scaladsl/TestSource.scala +++ b/stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/scaladsl/TestSource.scala @@ -27,12 +27,6 @@ import pekko.stream.testkit.StreamTestKit.ProbeSource */ object TestSource { - /** - * A Source that materializes to a [[pekko.stream.testkit.TestPublisher]]. - */ - @deprecated("Use `TestSource.apply` with implicit ClassicActorSystemProvider instead of ActorSystem", "1.3.0") - def probe[T](implicit system: ActorSystem): Source[T, TestPublisher.Probe[T]] = apply() - /** * A Source that materializes to a [[pekko.stream.testkit.TestPublisher]]. */ --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
