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.git
The following commit(s) were added to refs/heads/main by this push:
new bd24ae69fd remove deprecated monitor operation (#2056)
bd24ae69fd is described below
commit bd24ae69fd22c0c3d9f6de9116ee434ad376e215
Author: PJ Fanning <[email protected]>
AuthorDate: Sat Aug 23 11:39:46 2025 +0100
remove deprecated monitor operation (#2056)
* remove deprecated monitor operation
* Update remove-deprecated-methods.excludes
---
.../remove-deprecated-methods.excludes | 3 +++
.../main/scala/org/apache/pekko/stream/scaladsl/Flow.scala | 11 -----------
2 files changed, 3 insertions(+), 11 deletions(-)
diff --git
a/stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes
b/stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes
index a6d57bf826..0bb9dd22ea 100644
---
a/stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes
+++
b/stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes
@@ -140,9 +140,11 @@
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scal
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.FileIO.toFile*")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Flow.lazyInitAsync")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Flow.lazyInit")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Flow.monitor")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Flow.setup")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Flow.throttleEven")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.FlowOps.throttleEven")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.FlowOpsMat.monitor")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.GraphApply.create")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.GraphDSL.create")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.GraphDSL#Implicits#PortOpsImpl.throttleEven")
@@ -166,6 +168,7 @@
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scal
ProblemFilters.exclude[VirtualStaticMemberProblem]("org.apache.pekko.stream.scaladsl.Source.combine")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Source.lazilyAsync")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Source.lazily")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Source.monitor")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Source.fromFutureSource")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Source.fromCompletionStage")
ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Source.fromFuture")
diff --git a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
index 49c8ce7d07..b77be6cc03 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
@@ -4425,17 +4425,6 @@ trait FlowOpsMat[+Out, +Mat] extends FlowOps[Out, Mat] {
*/
def mapMaterializedValue[Mat2](f: Mat => Mat2): ReprMat[Out, Mat2]
- /**
- * Materializes to `FlowMonitor[Out]` that allows monitoring of the current
flow. All events are propagated
- * by the monitor unchanged. Note that the monitor inserts a memory barrier
every time it processes an
- * event, and may therefor affect performance.
- *
- * The `combine` function is used to combine the `FlowMonitor` with this
flow's materialized value.
- */
- @deprecated("Use monitor() or monitorMat(combine) instead", "Akka 2.5.17")
- def monitor[Mat2]()(combine: (Mat, FlowMonitor[Out]) => Mat2): ReprMat[Out,
Mat2] =
- viaMat(GraphStages.monitor)(combine)
-
/**
* Materializes to `FlowMonitor[Out]` that allows monitoring of the current
flow. All events are propagated
* by the monitor unchanged. Note that the monitor inserts a memory barrier
every time it processes an
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
