From 6470463b50dc2840be243f845e202f4cbf7260ef Mon Sep 17 00:00:00 2001 From: Johannes Rudolph Date: Sat, 19 Nov 2016 14:09:03 +0100 Subject: [PATCH] =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. --- .../akka/stream/impl/io/compression/CompressionUtils.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/io/compression/CompressionUtils.scala b/akka-stream/src/main/scala/akka/stream/impl/io/compression/CompressionUtils.scala index 6d5b7d923e..4a4d4dfc4f 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/io/compression/CompressionUtils.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/io/compression/CompressionUtils.scala @@ -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) }