Package org.apache.pekko.stream.scaladsl

Class Compression$

java.lang.Object

org.apache.pekko.stream.scaladsl.Compression$

public class Compression$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static Compression$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
Compression$()

Method Summary

Modifier and Type	Method	Description
Flow<ByteString,ByteString,NotUsed>	deflate()	Creates a flow that deflate-compresses a stream of ByteString.
Flow<ByteString,ByteString,NotUsed>	deflate(int level, boolean nowrap)	Same as deflate() with configurable level and nowrap
Flow<ByteString,ByteString,NotUsed>	gunzip(int maxBytesPerChunk)	Creates a Flow that decompresses a gzip-compressed stream of data.
int	gunzip$default$1()
Flow<ByteString,ByteString,NotUsed>	gzip()	Creates a flow that gzip-compresses a stream of ByteStrings.
Flow<ByteString,ByteString,NotUsed>	gzip(int level)	Same as gzip() with a custom level.
Flow<ByteString,ByteString,NotUsed>	inflate(int maxBytesPerChunk)	Creates a Flow that decompresses a deflate-compressed stream of data.
Flow<ByteString,ByteString,NotUsed>	inflate(int maxBytesPerChunk, boolean nowrap)	Creates a Flow that decompresses a deflate-compressed stream of data.
int	inflate$default$1()
int	MaxBytesPerChunkDefault()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final Compression$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Compression$

public Compression$()

Method Detail

MaxBytesPerChunkDefault

public final int MaxBytesPerChunkDefault()

gzip

public Flow<ByteString,ByteString,NotUsed> gzip()

Creates a flow that gzip-compresses a stream of ByteStrings. Note that the compressor will SYNC_FLUSH after every pekko.util.ByteString 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.

FIXME: should strategy / flush mode be configurable? See https://github.com/akka/akka/issues/21849

gzip

public Flow<ByteString,ByteString,NotUsed> gzip(int level)

Same as gzip() with a custom level.

Parameters:

level - Compression level (0-9)

gunzip

public Flow<ByteString,ByteString,NotUsed> gunzip(int maxBytesPerChunk)

Creates a Flow that decompresses a gzip-compressed stream of data.

Parameters:

maxBytesPerChunk - Maximum length of an output pekko.util.ByteString chunk.

gunzip$default$1

public int gunzip$default$1()

deflate

public Flow<ByteString,ByteString,NotUsed> deflate()

Creates a flow that deflate-compresses a stream of ByteString. Note that the compressor will SYNC_FLUSH after every pekko.util.ByteString 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.

FIXME: should strategy / flush mode be configurable? See https://github.com/akka/akka/issues/21849

deflate

public Flow<ByteString,ByteString,NotUsed> deflate(int level,
                                                               boolean nowrap)

Same as deflate() with configurable level and nowrap

Parameters:

level - Compression level (0-9)

nowrap - if true then use GZIP compatible compression

inflate

public Flow<ByteString,ByteString,NotUsed> inflate(int maxBytesPerChunk)

Creates a Flow that decompresses a deflate-compressed stream of data.

Parameters:

maxBytesPerChunk - Maximum length of an output pekko.util.ByteString chunk.

inflate

public Flow<ByteString,ByteString,NotUsed> inflate(int maxBytesPerChunk,
                                                               boolean nowrap)

Creates a Flow that decompresses a deflate-compressed stream of data.

Parameters:

maxBytesPerChunk - Maximum length of an output pekko.util.ByteString chunk.

nowrap - if true then use GZIP compatible decompression

inflate$default$1

public int inflate$default$1()