We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e566242 commit e310b3aCopy full SHA for e310b3a
http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala
@@ -721,12 +721,11 @@ private[http] object HttpServerBluePrint {
721
})
722
723
private var activeTimers = 0
724
- private val timeout: FiniteDuration = {
+ private val timeout: FiniteDuration =
725
inheritedAttributes.get[ActorAttributes.StreamSubscriptionTimeout] match {
726
case Some(attr) => attr.timeout
727
case None => 5.minutes // should not happen
728
}
729
- }
730
private def addTimeout(s: SubscriptionTimeout): Unit = {
731
if (activeTimers == 0) setKeepGoing(true)
732
activeTimers += 1
0 commit comments