extractStrictEntity
extractStrictEntity
Description
Extracts the strict http entity as HttpEntity.Strict from the RequestContext.
A timeout parameter is given and if the stream isn't completed after the timeout, the directive will be failed.
警告
The directive will read the request entity into memory within the size limit(8M by default) and effectively disable streaming.
The size limit can be configured globally with akka.http.parsing.max-content-length or
overridden by wrapping with withSizeLimit or withoutSizeLimit directive.
Example
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");
Contents
