This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 0c01ab4242 chore: Remove unused attributes in Stages.
0c01ab4242 is described below
commit 0c01ab4242bbacb516e266d56287972b87ef7d05
Author: He-Pin <[email protected]>
AuthorDate: Sat Jan 20 17:51:19 2024 +0800
chore: Remove unused attributes in Stages.
---
...991-remove-unused-attributes.backwards.excludes | 26 ++++++++++++++++++++++
.../org/apache/pekko/stream/impl/Stages.scala | 8 -------
2 files changed, 26 insertions(+), 8 deletions(-)
diff --git
a/stream/src/main/mima-filters/1.0.x.backwards.excludes/pr-991-remove-unused-attributes.backwards.excludes
b/stream/src/main/mima-filters/1.0.x.backwards.excludes/pr-991-remove-unused-attributes.backwards.excludes
new file mode 100644
index 0000000000..f9c33ff2a2
--- /dev/null
+++
b/stream/src/main/mima-filters/1.0.x.backwards.excludes/pr-991-remove-unused-attributes.backwards.excludes
@@ -0,0 +1,26 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+# Remove unused attributes in Stages.
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.Stages#DefaultAttributes.fused")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.Stages#DefaultAttributes.materializedValueSource")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.Stages#DefaultAttributes.concatAll")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.Stages#DefaultAttributes.processorWithKey")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.Stages#DefaultAttributes.concatSource")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.Stages#DefaultAttributes.concatMatSource")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.Stages#DefaultAttributes.actorPublisherSource")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.Stages#DefaultAttributes.actorSubscriberSink")
diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/Stages.scala
b/stream/src/main/scala/org/apache/pekko/stream/impl/Stages.scala
index 6bb286bd5a..32fcf8cfa3 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/impl/Stages.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/impl/Stages.scala
@@ -29,8 +29,6 @@ import pekko.stream.Attributes._
val inputBufferOne = inputBuffer(initial = 1, max = 1)
// stage specific default attributes
- val fused = name("fused")
- val materializedValueSource = name("matValueSource")
val map = name("map")
val contramap = name("contramap")
val dimap = name("dimap")
@@ -79,9 +77,7 @@ import pekko.stream.Attributes._
val prefixAndTail = name("prefixAndTail")
val flatMapPrefix = name("flatMapPrefix")
val split = name("split")
- val concatAll = name("concatAll")
val processor = name("processor")
- val processorWithKey = name("processorWithKey")
val identityOp = name("identityOp")
val delimiterFraming = name("delimiterFraming")
@@ -131,10 +127,7 @@ import pekko.stream.Attributes._
val maybeSource = name("MaybeSource")
val neverSource = name("neverSource")
val failedSource = name("failedSource")
- val concatSource = name("concatSource")
- val concatMatSource = name("concatMatSource")
val subscriberSource = name("subscriberSource")
- val actorPublisherSource = name("actorPublisherSource")
val actorRefSource = name("actorRefSource")
val actorRefWithBackpressureSource = name("actorRefWithBackpressureSource")
val queueSource = name("queueSource")
@@ -161,7 +154,6 @@ import pekko.stream.Attributes._
val neverSink = name("neverSink")
val actorRefSink = name("actorRefSink")
val actorRefWithBackpressureSink = name("actorRefWithBackpressureSink")
- val actorSubscriberSink = name("actorSubscriberSink")
val queueSink = name("queueSink")
val lazySink = name("lazySink")
val lazyFlow = name("lazyFlow")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
