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)
           }