public static interface HttpMessage.MessageTransformations<Self>
Modifier and Type | Method and Description |
---|---|
<T> Self |
addAttribute(AttributeKey<T> key,
T value) |
Self |
addCredentials(HttpCredentials credentials)
Returns a copy of this message with the given http credential header added to the list of
headers.
|
Self |
addHeader(HttpHeader header)
Returns a copy of this message with the given header added to the list of headers.
|
Self |
addHeaders(java.lang.Iterable<HttpHeader> headers)
Returns a copy of this message with the given headers added to the list of headers.
|
Self |
removeAttribute(AttributeKey<?> key)
Returns a copy of this message with the attribute with this key (if any) removed.
|
Self |
removeHeader(java.lang.String headerName)
Returns a copy of this message with all headers of the given name (case-insensitively)
removed.
|
java.util.concurrent.CompletionStage<? extends Self> |
toStrict(long timeoutMillis,
org.apache.pekko.actor.ClassicActorSystemProvider system)
Returns a CompletionStage of Self message with strict entity that contains the same data as
this entity which is only completed when the complete entity has been collected.
|
java.util.concurrent.CompletionStage<? extends Self> |
toStrict(long timeoutMillis,
java.util.concurrent.Executor ec,
org.apache.pekko.stream.Materializer materializer)
Returns a CompletionStage of Self message with strict entity that contains the same data as
this entity which is only completed when the complete entity has been collected.
|
java.util.concurrent.CompletionStage<? extends Self> |
toStrict(long timeoutMillis,
long maxBytes,
org.apache.pekko.actor.ClassicActorSystemProvider system)
Returns a CompletionStage of Self message with strict entity that contains the same data as
this entity which is only completed when the complete entity has been collected.
|
java.util.concurrent.CompletionStage<? extends Self> |
toStrict(long timeoutMillis,
long maxBytes,
java.util.concurrent.Executor ec,
org.apache.pekko.stream.Materializer materializer)
Returns a CompletionStage of Self message with strict entity that contains the same data as
this entity which is only completed when the complete entity has been collected.
|
<T> Self |
transformEntityDataBytes(org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>,T> transformer)
Returns a copy of Self message after applying the given transformation
|
Self |
withEntity(byte[] bytes)
Returns a copy of Self message with a new entity.
|
Self |
withEntity(org.apache.pekko.util.ByteString bytes)
Returns a copy of Self message with a new entity.
|
Self |
withEntity(ContentType.NonBinary type,
java.lang.String string)
Returns a copy of Self message with a new entity.
|
Self |
withEntity(ContentType type,
byte[] bytes)
Returns a copy of Self message with a new entity.
|
Self |
withEntity(ContentType type,
org.apache.pekko.util.ByteString bytes)
Returns a copy of Self message with a new entity.
|
Self |
withEntity(ContentType type,
java.io.File file)
Returns a copy of Self message with a new entity.
|
Self |
withEntity(ContentType type,
java.nio.file.Path file)
Returns a copy of Self message with a new entity.
|
Self |
withEntity(RequestEntity entity)
Returns a copy of Self message with a new entity.
|
Self |
withEntity(java.lang.String string)
Returns a copy of this message with a new entity.
|
Self |
withHeaders(java.lang.Iterable<HttpHeader> headers)
Returns a copy of this message with new headers.
|
Self |
withProtocol(HttpProtocol protocol)
Returns a copy of this message with a new protocol.
|
Self withProtocol(HttpProtocol protocol)
Self addHeader(HttpHeader header)
Self addHeaders(java.lang.Iterable<HttpHeader> headers)
Self withHeaders(java.lang.Iterable<HttpHeader> headers)
<T> Self addAttribute(AttributeKey<T> key, T value)
Self addCredentials(HttpCredentials credentials)
Self removeHeader(java.lang.String headerName)
Self removeAttribute(AttributeKey<?> key)
Self withEntity(java.lang.String string)
Self withEntity(byte[] bytes)
Self withEntity(org.apache.pekko.util.ByteString bytes)
Self withEntity(ContentType.NonBinary type, java.lang.String string)
Self withEntity(ContentType type, byte[] bytes)
Self withEntity(ContentType type, org.apache.pekko.util.ByteString bytes)
Self withEntity(ContentType type, java.io.File file)
Self withEntity(ContentType type, java.nio.file.Path file)
Self withEntity(RequestEntity entity)
<T> Self transformEntityDataBytes(org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>,T> transformer)
java.util.concurrent.CompletionStage<? extends Self> toStrict(long timeoutMillis, java.util.concurrent.Executor ec, org.apache.pekko.stream.Materializer materializer)
Use getEntity().getDataBytes and stream processing instead if the expected data is big or is likely to take a long time.
java.util.concurrent.CompletionStage<? extends Self> toStrict(long timeoutMillis, long maxBytes, java.util.concurrent.Executor ec, org.apache.pekko.stream.Materializer materializer)
Use getEntity().getDataBytes and stream processing instead if the expected data is big or is likely to take a long time.
java.util.concurrent.CompletionStage<? extends Self> toStrict(long timeoutMillis, org.apache.pekko.actor.ClassicActorSystemProvider system)
Use getEntity().getDataBytes and stream processing instead if the expected data is big or is likely to take a long time.
java.util.concurrent.CompletionStage<? extends Self> toStrict(long timeoutMillis, long maxBytes, org.apache.pekko.actor.ClassicActorSystemProvider system)
Use getEntity().getDataBytes and stream processing instead if the expected data is big or is likely to take a long time.