extractRequestTimeout

def extractRequestTimeout: Directive1[Duration] 

Description

This directive extracts the currently set request timeout.

For more information about various timeouts in Apache Pekko HTTP see Pekko HTTP Timeouts.

Example

Scala

copysourceval timeout1 = 500.millis
val timeout2 = 1000.millis
val route =
  path("timeout") {
    withRequestTimeout(timeout1) {
      extractRequestTimeout { t1 =>
        withRequestTimeout(timeout2) {
          extractRequestTimeout { t2 =>
            complete(
              if (t1 == timeout1 && t2 == timeout2) StatusCodes.OK
              else StatusCodes.InternalServerError)
          }
        }
      }
    }
  }

Java

copysourceDuration timeout1 = Duration.create(500, TimeUnit.MILLISECONDS);
Duration timeout2 = Duration.create(1000, TimeUnit.MILLISECONDS);
Route route =
    path(
        "timeout",
        () ->
            withRequestTimeout(
                timeout1,
                () ->
                    extractRequestTimeout(
                        t1 ->
                            withRequestTimeout(
                                timeout2,
                                () ->
                                    extractRequestTimeout(
                                        t2 -> {
                                          if (t1 == timeout1 && t2 == timeout2)
                                            return complete(StatusCodes.OK);
                                          else
                                            return complete(StatusCodes.INTERNAL_SERVER_ERROR);
                                        })))));