Package akka.stream.javadsl

Class Compression$

java.lang.Object

akka.stream.javadsl.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 gzip-compressed stream of data.
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 deflate-compressed stream of data.
Flow<ByteString,ByteString,NotUsed>	inflate(int maxBytesPerChunk, boolean nowrap)	Same as inflate(int) with configurable maximum output length and nowrap

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

gunzip

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

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

Parameters:

maxBytesPerChunk - Maximum length of the output ByteString chunk.

inflate

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

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

Parameters:

maxBytesPerChunk - Maximum length of the output ByteString chunk.

inflate

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

Same as inflate(int) with configurable maximum output length and nowrap

Parameters:

maxBytesPerChunk - Maximum length of the output ByteString chunk.

nowrap - if true then use GZIP compatible decompression

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 ByteString so that it is guaranteed that every 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.

gzip

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

Same as gzip() with a custom level.

Parameters:

level - Compression level (0-9)

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 ByteString so that it is guaranteed that every 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.

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