public static final class HttpEntity.Strict extends java.lang.Object implements HttpEntity.Strict, UniversalEntity, scala.Product, scala.Serializable
HttpEntity.Chunk, HttpEntity.Chunk$, HttpEntity.Chunked, HttpEntity.Chunked$, HttpEntity.ChunkStreamPart, HttpEntity.ChunkStreamPart$, HttpEntity.CloseDelimited, HttpEntity.CloseDelimited$, HttpEntity.Default, HttpEntity.Default$, HttpEntity.DiscardedEntity, HttpEntity.HttpEntityScalaDSLSugar, HttpEntity.HttpEntityScalaDSLSugar$, HttpEntity.IndefiniteLength, HttpEntity.IndefiniteLength$, HttpEntity.LastChunk, HttpEntity.LastChunk$, HttpEntity.Strict, HttpEntity.Strict$, HttpEntity.WithoutKnownLength
EMPTY
Constructor and Description |
---|
Strict(ContentType contentType,
akka.util.ByteString data) |
Modifier and Type | Method and Description |
---|---|
long |
contentLength() |
ContentType |
contentType()
The
ContentType associated with this entity. |
akka.util.ByteString |
data() |
akka.stream.scaladsl.Source<akka.util.ByteString,akka.NotUsed> |
dataBytes()
A stream of the data of this entity.
|
akka.util.ByteString |
getData()
Java API
|
boolean |
isKnownEmpty()
Returns if this entity is known to be empty.
|
java.lang.String |
productPrefix() |
scala.concurrent.Future<HttpEntity.Strict> |
toStrict(scala.concurrent.duration.FiniteDuration timeout,
akka.stream.Materializer fm)
Collects all possible parts and returns a potentially future Strict entity for easier processing.
|
java.lang.String |
toString() |
RequestEntity |
transformDataBytes(akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,java.lang.Object> transformer)
Returns a copy of the given entity with the ByteString chunks of this entity transformed by the given transformer.
|
UniversalEntity |
transformDataBytes(long newContentLength,
akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,java.lang.Object> transformer)
Transforms this' entities data bytes with a transformer that will produce exactly the number of bytes given as
newContentLength . |
HttpEntity.Strict |
withContentType(ContentType contentType)
Creates a copy of this HttpEntity with the
contentType overridden with the given one. |
UniversalEntity |
withoutSizeLimit()
Lift the size limit from this entity by returning a new entity instance which skips the size verification.
|
UniversalEntity |
withSizeLimit(long maxBytes)
Apply the given size limit to this entity by returning a new entity instance which automatically verifies that the
data stream encapsulated by this instance produces at most `maxBytes` data bytes.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
contentLengthOption
completionStageCovariant, discardBytes, getContentLengthOption, getContentType, getDataBytes, isChunked, isCloseDelimited, isDefault, isIndefiniteLength, toStrict, toStrict, toStrict, withContentType
public Strict(ContentType contentType, akka.util.ByteString data)
public ContentType contentType()
HttpEntity
ContentType
associated with this entity.public akka.util.ByteString data()
public long contentLength()
public boolean isKnownEmpty()
HttpEntity
isKnownEmpty
in interface HttpEntity
public akka.stream.scaladsl.Source<akka.util.ByteString,akka.NotUsed> dataBytes()
HttpEntity
public scala.concurrent.Future<HttpEntity.Strict> toStrict(scala.concurrent.duration.FiniteDuration timeout, akka.stream.Materializer fm)
HttpEntity
akka.http.parsing.max-to-strict-bytes
. Not that this method does not support different
defaults for client- and server use: if you want that, use the toStrict
method and pass in an explicit
maximum number of bytes.timeout
- (undocumented)fm
- (undocumented)public RequestEntity transformDataBytes(akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,java.lang.Object> transformer)
HttpEntity
Chunked
entity, the chunks will be transformed one by one keeping the chunk metadata (but may introduce an
extra chunk before the LastChunk
if transformer.onTermination
returns additional data).
This method may only throw an exception if the transformer
function throws an exception while creating the transformer.
Any other errors are reported through the new entity data stream.
transformer
- (undocumented)public UniversalEntity transformDataBytes(long newContentLength, akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,java.lang.Object> transformer)
UniversalEntity
newContentLength
.newContentLength
- (undocumented)transformer
- (undocumented)public HttpEntity.Strict withContentType(ContentType contentType)
HttpEntity
contentType
overridden with the given one.contentType
- (undocumented)public UniversalEntity withSizeLimit(long maxBytes)
HttpEntity
withSizeLimit
in interface HttpEntity
maxBytes
- (undocumented)public UniversalEntity withoutSizeLimit()
HttpEntity
withoutSizeLimit
in interface HttpEntity
public java.lang.String productPrefix()
productPrefix
in interface scala.Product
public java.lang.String toString()
toString
in class java.lang.Object
public akka.util.ByteString getData()
getData
in interface HttpEntity.Strict