try using attributes to get the timeout

Author: pjfanning

http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

@@ -714,10 +714,11 @@ private[http] object HttpServerBluePrint {
         })
 
       private var activeTimers = 0
-      private val timeout = {
-        import scala.jdk.DurationConverters._
-        materializer.system.settings.config.getDuration(
-          "pekko.stream.materializer.stream-ref.subscription-timeout").toScala
+      private val timeout: FiniteDuration = {
+        inheritedAttributes.get[ActorAttributes.StreamSubscriptionTimeout] match {
+          case Some(attr) => attr.timeout
+          case None       => 5.minutes // should not happen
+        }
       }
       private def addTimeout(s: SubscriptionTimeout): Unit = {
         if (activeTimers == 0) setKeepGoing(true)