extractStrictEntity

def extractStrictEntity(timeout: FiniteDuration): Directive1[HttpEntity.Strict] 
def extractStrictEntity(timeout: FiniteDuration, maxBytes: Long): Directive1[HttpEntity.Strict] 

Description

Extracts the strict http entity as HttpEntity.Strict from the RequestContextRequestContext.

A timeout parameter is given and if the stream isn’t completed after the timeout, the directive will be failed.

Example

Scala

copysourceimport scala.concurrent.duration._

val route = extractStrictEntity(3.seconds) { entity =>
  complete(entity.data.utf8String)
}

// tests:
val dataBytes = Source.fromIterator(() => Iterator.range(1, 10).map(x => ByteString(x.toString)))
Post("/", HttpEntity(ContentTypes.`text/plain(UTF-8)`, data = dataBytes)) ~> route ~> check {
  responseAs[String] shouldEqual "123456789"
}

Java

copysourceimport static org.apache.pekko.http.javadsl.server.Directives.extractStrictEntity;

final FiniteDuration timeout = FiniteDuration.create(3, TimeUnit.SECONDS);
final Route route =
    extractStrictEntity(timeout, strict -> complete(strict.getData().utf8String()));

// tests:
final Iterator iterator =
    Arrays.asList(
            ByteString.fromString("1"), ByteString.fromString("2"), ByteString.fromString("3"))
        .iterator();
final Source<ByteString, NotUsed> dataBytes = Source.fromIterator(() -> iterator);
testRoute(route)
    .run(
        HttpRequest.POST("/")
            .withEntity(HttpEntities.create(ContentTypes.TEXT_PLAIN_UTF8, dataBytes)))
    .assertEntity("123");