From dd289e7e2e424e2c5bed62fdbe0921e156118042 Mon Sep 17 00:00:00 2001 From: Johannes Rudolph Date: Thu, 1 Jul 2021 13:58:36 +0200 Subject: [PATCH] stream: actually read coalesce-writes setting from config (#30353) --- .../src/main/scala/akka/stream/ActorMaterializer.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/ActorMaterializer.scala b/akka-stream/src/main/scala/akka/stream/ActorMaterializer.scala index f5e9705c6f..47b85ea8ff 100644 --- a/akka-stream/src/main/scala/akka/stream/ActorMaterializer.scala +++ b/akka-stream/src/main/scala/akka/stream/ActorMaterializer.scala @@ -778,7 +778,9 @@ object IOSettings { "Use setting 'akka.stream.materializer.io.tcp.write-buffer-size' or attribute TcpAttributes.writeBufferSize instead", "2.6.0") def apply(config: Config): IOSettings = - new IOSettings(tcpWriteBufferSize = math.min(Int.MaxValue, config.getBytes("tcp.write-buffer-size")).toInt) + new IOSettings( + tcpWriteBufferSize = math.min(Int.MaxValue, config.getBytes("tcp.write-buffer-size")).toInt, + coalesceWrites = config.getInt("tcp.coalesce-writes")) @deprecated( "Use setting 'akka.stream.materializer.io.tcp.write-buffer-size' or attribute TcpAttributes.writeBufferSize instead",