object Compression
- Source
- Compression.scala
- Alphabetic
- By Inheritance
- Compression
- 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
- final val MaxBytesPerChunkDefault: Int(65536)
- 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 deflate(level: Int, nowrap: Boolean, autoFlush: Boolean): Flow[ByteString, ByteString, NotUsed]
Same as deflate with configurable level, nowrap and autoFlush.
Same as deflate with configurable level, nowrap and autoFlush.
- level
Compression level (0-9)
- nowrap
if true then use GZIP compatible compression
- autoFlush
If true will automatically flush after every single element in the stream.
- Since
1.3.0
- def deflate(level: Int, nowrap: Boolean): Flow[ByteString, ByteString, NotUsed]
Same as deflate with configurable level and nowrap
Same as deflate with configurable level and nowrap
- level
Compression level (0-9)
- nowrap
if true then use GZIP compatible compression
- def deflate: Flow[ByteString, ByteString, NotUsed]
Creates a flow that deflate-compresses a stream of ByteString.
Creates a flow that deflate-compresses a stream of ByteString. Note that the compressor will flush after every single element in stream so that it is guaranteed that every pekko.util.ByteString coming out of the flow can be fully decompressed without waiting for additional data. This may come at a compression performance cost for very small chunks.
- 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 gzip(level: Int, autoFlush: Boolean): Flow[ByteString, ByteString, NotUsed]
Same as gzip with a custom level and configurable flush mode.
Same as gzip with a custom level and configurable flush mode.
- level
Compression level (0-9)
- autoFlush
If true will automatically flush after every single element in the stream.
- Since
1.3.0
- def gzip(level: Int): Flow[ByteString, ByteString, NotUsed]
Same as gzip with a custom level.
Same as gzip with a custom level.
- level
Compression level (0-9)
- def gzip: Flow[ByteString, ByteString, NotUsed]
Creates a flow that gzip-compresses a stream of ByteStrings.
Creates a flow that gzip-compresses a stream of ByteStrings. Note that the compressor will flush after every single element in stream so that it is guaranteed that every pekko.util.ByteString coming out of the flow can be fully decompressed without waiting for additional data. This may come at a compression performance cost for very small chunks.
- def gzipDecompress(maxBytesPerChunk: Int = MaxBytesPerChunkDefault): Flow[ByteString, ByteString, NotUsed]
Creates a Flow that decompresses a gzip-compressed stream of data.
Creates a Flow that decompresses a gzip-compressed stream of data.
- maxBytesPerChunk
Maximum length of an output pekko.util.ByteString chunk.
- Since
1.3.0
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def inflate(maxBytesPerChunk: Int, nowrap: Boolean): Flow[ByteString, ByteString, NotUsed]
Creates a Flow that decompresses a deflate-compressed stream of data.
Creates a Flow that decompresses a deflate-compressed stream of data.
- maxBytesPerChunk
Maximum length of an output pekko.util.ByteString chunk.
- nowrap
if true then use GZIP compatible decompression
- def inflate(maxBytesPerChunk: Int = MaxBytesPerChunkDefault): Flow[ByteString, ByteString, NotUsed]
Creates a Flow that decompresses a deflate-compressed stream of data.
Creates a Flow that decompresses a deflate-compressed stream of data.
- maxBytesPerChunk
Maximum length of an output pekko.util.ByteString chunk.
- 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])