New to Akka? Start with the Akka SDK.
Compression.gunzip
Creates a flow that gzip-decompresses a stream of ByteStrings.
Signature
Compression.gunzipCompression.gunzip
Description
Creates a flow that gzip-decompresses a stream of ByteStrings. If the input is truncated, uses invalid compression method or is invalid (failed CRC checks) this operator fails with a java.util.zip.ZipException.
Reactive Streams semantics
emits when the decompression algorithm produces output for the received ByteString (the emitted ByteString is of maxBytesPerChunk maximum length)
backpressures when downstream backpressures
completes when upstream completes