=str #21395 fix default flushing in Deflate/Gzip compression

This was accidentally lost during the move from akka-http.

Otherwise, it isn't possible to decompress chunk-by-chunk because the
implementation will internally buffer data.
This commit is contained in:
Johannes Rudolph 2016-11-19 14:09:03 +01:00 committed by Konrad Malawski
parent 2c32a7cde9
commit 6470463b50

View file

@ -22,7 +22,7 @@ private[stream] object CompressionUtils {
val compressor = newCompressor()
override def onPush(): Unit = {
val data = compressor.compress(grab(in))
val data = compressor.compressAndFlush(grab(in))
if (data.nonEmpty) push(out, data)
else pull(in)
}