This documentation regards version 2.10.4+3-f7095f01-SNAPSHOT, however the current version is 2.10.4.
Compression.gunzip
Creates a flow that gzip-decompresses a stream of ByteStrings.
Signature
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