requestEntityPresent

def requestEntityPresent: Directive0 

Description

A simple filter that checks if the request entity is present and only then passes processing to the inner route. Otherwise, the request is rejected with RequestEntityExpectedRejectionRequestEntityExpectedRejection.

See also requestEntityEmpty for the opposite effect.

Example

Scala

copysourceval route =
  concat(
    requestEntityEmpty {
      complete("request entity empty")
    },
    requestEntityPresent {
      complete("request entity present")
    })

// tests:
Post("/", "text") ~> Route.seal(route) ~> check {
  responseAs[String] shouldEqual "request entity present"
}
Post("/") ~> route ~> check {
  responseAs[String] shouldEqual "request entity empty"
}

Java

copysourceimport static org.apache.pekko.http.javadsl.server.Directives.complete;
import static org.apache.pekko.http.javadsl.server.Directives.requestEntityEmpty;
import static org.apache.pekko.http.javadsl.server.Directives.requestEntityPresent;

final Route route =
    requestEntityEmpty(() -> complete("request entity empty"))
        .orElse(requestEntityPresent(() -> complete("request entity present")));

// tests:
testRoute(route).run(HttpRequest.POST("/")).assertEntity("request entity empty");
testRoute(route)
    .run(HttpRequest.POST("/").withEntity("foo"))
    .assertEntity("request entity present");