Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -414,17 +414,13 @@
import pekko.http.impl.util.JavaMapping.Implicits._

/** JAVA API * */
override def updateTimeout(timeout: java.time.Duration): Unit = {
val stimeout = if (timeout eq null) null else timeout.asScala
update(stimeout, null: HttpRequest => HttpResponse)
}
override def updateTimeout(timeout: java.time.Duration): Unit =
update(timeout.asScala, null: HttpRequest => HttpResponse)
override def update(timeout: Duration, handler: Function[model.HttpRequest, model.HttpResponse]): Unit =
update(timeout, handler(_: HttpRequest).asScala)
override def update(
timeout: java.time.Duration, handler: Function[model.HttpRequest, model.HttpResponse]): Unit = {
val stimeout = if (timeout eq null) null else timeout.asScala
update(stimeout, handler(_: HttpRequest).asScala)
}
timeout: java.time.Duration, handler: Function[model.HttpRequest, model.HttpResponse]): Unit =
update(timeout.asScala, handler(_: HttpRequest).asScala)
override def updateHandler(handler: Function[model.HttpRequest, model.HttpResponse]): Unit =
updateHandler(handler(_: HttpRequest).asScala)

Expand Down Expand Up @@ -733,7 +729,7 @@
})

private var activeTimers = 0
private def timeout = materializer.settings.subscriptionTimeoutSettings.timeout

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / validate-links

method settings in class Materializer is deprecated (since Akka 2.6.0): Use attributes to access settings from stages

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / validate-links

value timeout in class StreamSubscriptionTimeoutSettings is deprecated (since Akka 2.6.0): Use attribute 'ActorAttributes.StreamSubscriptionTimeout' to read the concrete setting value

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / Compile and test (2.12, 11)

method settings in class Materializer is deprecated (since Akka 2.6.0): Use attributes to access settings from stages

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / Compile and test (2.12, 11)

value timeout in class StreamSubscriptionTimeoutSettings is deprecated (since Akka 2.6.0): Use attribute 'ActorAttributes.StreamSubscriptionTimeout' to read the concrete setting value

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / Compile and test (2.12, 8)

method settings in class Materializer is deprecated (since Akka 2.6.0): Use attributes to access settings from stages

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / Compile and test (2.12, 8)

value timeout in class StreamSubscriptionTimeoutSettings is deprecated (since Akka 2.6.0): Use attribute 'ActorAttributes.StreamSubscriptionTimeout' to read the concrete setting value

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / Compile and test (2.13, 8)

method settings in class Materializer is deprecated (since Akka 2.6.0): Use attributes to access settings from stages

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / Compile and test (2.13, 8)

value timeout in class StreamSubscriptionTimeoutSettings is deprecated (since Akka 2.6.0): Use attribute 'ActorAttributes.StreamSubscriptionTimeout' to read the concrete setting value

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / Compile and test (2.13, 11)

method settings in class Materializer is deprecated (since Akka 2.6.0): Use attributes to access settings from stages

Check warning on line 732 in http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala

View workflow job for this annotation

GitHub Actions / Compile and test (2.13, 11)

value timeout in class StreamSubscriptionTimeoutSettings is deprecated (since Akka 2.6.0): Use attribute 'ActorAttributes.StreamSubscriptionTimeout' to read the concrete setting value
private def addTimeout(s: SubscriptionTimeout): Unit = {
if (activeTimers == 0) setKeepGoing(true)
activeTimers += 1
Expand Down
Loading