Creates a flow that deflate-compresses a stream of ByteStrings.
Creates a flow that deflate-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.
Use the overload method with parameters to control the compression level and compatibility with GZip.
Reactive Streams semantics
emits when the compression algorithm produces output for the received
backpressures when downstream backpressures
completes when upstream completes (may emit finishing bytes in an extra