MiMa and keep compatibility by extending StreamTimeoutException

Author: johanandren

akka-stream/src/main/mima-filters/2.8.4.backwards.excludes/tcp-idle-timeout.excludes

@@ -0,0 +1,2 @@
+# Internal API changed
+ProblemFilters.exclude[DirectMissingMethodProblem]("akka.stream.impl.Timers#IdleTimeoutBidi.this")

akka-stream/src/main/scala/akka/stream/StreamTimeoutException.scala

@@ -15,7 +15,7 @@ import akka.annotation.DoNotInherit
  * Not for user extension
  */
 @DoNotInherit
-sealed class StreamTimeoutException(msg: String) extends TimeoutException(msg) with NoStackTrace
+class StreamTimeoutException(msg: String) extends TimeoutException(msg) with NoStackTrace
 
 final class InitialTimeoutException(msg: String) extends StreamTimeoutException(msg)
 

akka-stream/src/main/scala/akka/stream/impl/Timers.scala

@@ -151,10 +151,13 @@ import akka.stream.stage._
 
   }
 
+  private object IdleTimeoutBidi {
+    val defaultCreateFailure: FiniteDuration => Throwable = timeout =>
+      new StreamIdleTimeoutException(s"No elements passed in the last ${timeout.toCoarsest}.")
+  }
   final class IdleTimeoutBidi[I, O](
       val timeout: FiniteDuration,
-      createFailure: FiniteDuration => Throwable = timeout =>
-        new StreamIdleTimeoutException(s"No elements passed in the last ${timeout.toCoarsest}."))
+      createFailure: FiniteDuration => Throwable = IdleTimeoutBidi.defaultCreateFailure)
       extends GraphStage[BidiShape[I, I, O, O]] {
     val in1 = Inlet[I]("in1")
     val in2 = Inlet[O]("in2")

akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala

@@ -5,7 +5,6 @@
 package akka.stream.scaladsl
 
 import java.net.InetSocketAddress
-import java.util.concurrent.TimeoutException
 import javax.net.ssl.SSLContext
 import javax.net.ssl.SSLEngine
 import javax.net.ssl.SSLSession
@@ -508,7 +507,7 @@ final class Tcp(system: ExtendedActorSystem) extends akka.actor.Extension {
 }
 
 final class TcpIdleTimeoutException(msg: String, @unused timeout: Duration)
-    extends TimeoutException(msg: String)
+    extends StreamTimeoutException(msg: String)
     with NoStackTrace // only used from a single stage
 
 object TcpAttributes {