remove some deprecated code from streams module

stream/src/main/boilerplate/org/apache/pekko/stream/scaladsl/GraphApply.scala.template

@@ -27,21 +27,6 @@ trait GraphApply {
     createGraph(s, builder)
   }
 
-  /**
-   * Creates a new [[Graph]] by importing the given graph `g1` and passing its [[Shape]]
-   * along with the [[GraphDSL.Builder]] to the given create function.
-   *
-   * Deprecated: this method signature does not work with Scala 3 type inference, kept for binary compatibility. Use createGraph instead.
-   */
-  @deprecated("Use createGraph instead", "Akka 2.6.16")
-  def create[S <: Shape, Mat](g1: Graph[Shape, Mat])(buildBlock: GraphDSL.Builder[Mat] => (g1.Shape) => S): Graph[S, Mat] = {
-    val builder = new GraphDSL.Builder
-    val s1 = builder.add(g1, Keep.right)
-    val s = buildBlock(builder)(s1)
-
-    createGraph(s, builder)
-  }
-
   /**
    * Creates a new [[Graph]] by importing the given graph `g1` and passing its [[Shape]]
    * along with the [[GraphDSL.Builder]] to the given create function.
@@ -57,24 +42,6 @@ trait GraphApply {
 
   [2..#
 
-  /**
-   * Creates a new [[Graph]] by importing the given graphs and passing their [[Shape]]s
-   * along with the [[GraphDSL.Builder]] to the given create function.
-   *
-   * Deprecated: this method signature does not work with Scala 3 type inference, kept for binary compatibility. Use createGraph instead.
-   */
-  @deprecated("Use createGraph instead", "Akka ##2.6.##16")
-  def create[S <: Shape, Mat, [#M1#]]([#g1: Graph[Shape, M1]#])(combineMat: ([#M1#]) => Mat)(buildBlock: GraphDSL.Builder[Mat] => ([#g1.Shape#]) => S): Graph[S, Mat] = {
-    val builder = new GraphDSL.Builder
-    val curried = combineMat.curried
-    val s##1 = builder.add(g##1, (m##1: M##1) => curried(m##1))
-    [2..#val s1 = builder.add(g1, (f: M1 => Any, m1: M1) => f(m1))#
-    ]
-    val s = buildBlock(builder)([#s1#])
-
-    createGraph(s, builder)
-  }
-
   /**
    * Creates a new [[Graph]] by importing the given graphs and passing their [[Shape]]s
    * along with the [[GraphDSL.Builder]] to the given create function.

stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes

@@ -0,0 +1,53 @@
+# 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 deprecated methods
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.stream.FanInShape1N")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.UniformFanInShape.inSeq")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.UniformFanOutShape.outArray")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.stream.impl.ConstantFun*")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter#BatchingActorInputBoundary.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.fusing.PrefixAndTail#PrefixAndTailLogic.onDownstreamFinish")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.stream.impl.io.ByteStringParser$ParsingException")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.impl.io.ByteStringParser#ParsingLogic.onDownstreamFinish")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.stream.javadsl.CoupledTerminationFlow*")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.javadsl.RestartFlow.onFailuresWithBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.javadsl.RestartFlow.withBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.javadsl.RestartSink.withBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.javadsl.RestartSource.onFailuresWithBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.javadsl.RestartSource.withBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Balance.this")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.stream.scaladsl.CoupledTerminationFlow*")
+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.MergeHub#MergedSourceLogic.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.Partition.this")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.RestartFlow.onFailuresWithBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.RestartFlow.withBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.RestartSink.withBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.RestartSource.onFailuresWithBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.RestartSource.withBackoff")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.scaladsl.ZipWithN.inSeq")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.AbstractInOutHandler.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.AbstractOutHandler.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.GraphStageLogic#ConditionalTerminateOutput.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.GraphStageLogic#EagerTerminateOutput.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.GraphStageLogic#Emitting.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.GraphStageLogic#IgnoreTerminateOutput.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.OutHandler.onDownstreamFinish")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.TimerGraphStageLogic.schedulePeriodicallyWithInitialDelay")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.stream.stage.TimerGraphStageLogic.schedulePeriodically")

stream/src/main/scala/org/apache/pekko/stream/UniformFanInShape.scala

@@ -42,10 +42,5 @@ class UniformFanInShape[-T, +O](val n: Int, _init: FanInShape.Init[O]) extends F
   final override def inlets: immutable.Seq[Inlet[T @uncheckedVariance]] =
     super.inlets.asInstanceOf[immutable.Seq[Inlet[T]]]
 
-  @deprecated("Use 'inlets' or 'in(id)' instead.", "Akka 2.5.5")
-  def inSeq: immutable.IndexedSeq[Inlet[T @uncheckedVariance]] = _inSeq
-
-  // cannot deprecate a lazy val because of genjavadoc problem https://github.com/typesafehub/genjavadoc/issues/85
-  private lazy val _inSeq: immutable.IndexedSeq[Inlet[T @uncheckedVariance]] = inlets.toIndexedSeq
   def in(n: Int): Inlet[T @uncheckedVariance] = inlets(n)
 }

stream/src/main/scala/org/apache/pekko/stream/UniformFanOutShape.scala

@@ -36,10 +36,5 @@ class UniformFanOutShape[-I, +O](n: Int, _init: FanOutShape.Init[I @uncheckedVar
   final override def outlets: immutable.Seq[Outlet[O @uncheckedVariance]] =
     super.outlets.asInstanceOf[immutable.Seq[Outlet[O]]]
 
-  @deprecated("use 'outlets' or 'out(id)' instead", "Akka 2.5.5")
-  def outArray: Array[Outlet[O @uncheckedVariance]] = _outArray
-
-  // cannot deprecate a lazy val because of genjavadoc problem https://github.com/typesafehub/genjavadoc/issues/85
-  private lazy val _outArray: Array[Outlet[O @uncheckedVariance]] = outlets.toArray
   def out(n: Int): Outlet[O @uncheckedVariance] = outlets(n)
 }

stream/src/main/scala/org/apache/pekko/stream/impl/io/ByteStringParser.scala

@@ -187,9 +187,6 @@ import pekko.util.ByteString
       throw new IllegalStateException("no initial parser installed: you must use startWith(...)")
   }
 
-  @deprecated("Deprecated for internal usage. Will not be emitted any more.", "Akka 2.6.20")
-  class ParsingException(msg: String, cause: Throwable) extends RuntimeException(msg, cause)
-
   val NeedMoreData = new Exception with NoStackTrace
 
   class ByteReader(input: ByteString) {