object Coders
- Annotations
- @nowarn()
- Source
- Coders.scala
- Alphabetic
- By Inheritance
- Coders
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val DefaultCoders: Seq[Coder]
- def Deflate(messageFilter: (HttpMessage) => Boolean = Encoder.DefaultFilter, compressionLevel: Int = DeflateCompressor.DefaultCompressionLevel): Coder
- def Deflate: Coder
- def Gzip(messageFilter: (HttpMessage) => Boolean = Encoder.DefaultFilter, compressionLevel: Int = GzipCompressor.DefaultCompressionLevel): Coder
- def Gzip: Coder
- def NoCoding: Coder
- def Zstd(messageFilter: (HttpMessage) => Boolean = Encoder.DefaultFilter, compressionLevel: Int = pekko.http.scaladsl.coding.Zstd.DefaultCompressionLevel, windowLogMax: Int = pekko.http.scaladsl.coding.Zstd.DefaultWindowLogMax): Coder
A coder for the 'zstd' encoding with a custom message filter, compression level and decoder window limit, see Zstd.
A coder for the 'zstd' encoding with a custom message filter, compression level and decoder window limit, see Zstd.
- compressionLevel
must be between
Compression.ZstdMinCompressionLevelandCompression.ZstdMaxCompressionLevelof pekko-stream- windowLogMax
the log2 of the largest window that the decoder accepts, 23 (8 MB, the limit of RFC 9659) by default. It must be 0 or between
Compression.ZstdMinWindowLogandCompression.ZstdMaxWindowLogof pekko-stream; 0 uses the limit of libzstd (128 MB) and also works with versions of zstd-jni older than 1.5.7-25
- Since
2.0.0
- def Zstd: Coder
A coder for the 'zstd' encoding.
A coder for the 'zstd' encoding. It is not one of the DefaultCoders, as it needs the optional
com.github.luben:zstd-jnidependency on the classpath, version 1.5.7-25 or later.Following RFC 9659, it does not compress with a window larger than 8 MB, and does not decode frames that need a larger window, so that a peer cannot make it allocate more memory than that for one message.
- Since
2.0.0
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def decodeMessage(message: HttpMessage, decoders: Seq[Decoder] = DefaultCoders): Self
Decodes the message with the one of
decoderswhose encoding matches the message'sContent-Encodingheader, for example to decode a response on the client side without checking its encoding first.Decodes the message with the one of
decoderswhose encoding matches the message'sContent-Encodingheader, for example to decode a response on the client side without checking its encoding first.The message is returned unchanged if it has no
Content-Encodingheader, if none ofdecodersmatches its encoding, or if the header lists more than one encoding. In the last two cases theContent-Encodingheader is kept, somessage.encodingshows that the entity is still encoded.- decoders
the decoders to choose from, Zstd is not one of the DefaultCoders
- Since
2.0.0
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])