From 511a55f5627339820d1132e01d65d52e070f89ef Mon Sep 17 00:00:00 2001 From: Martynas Mickevicius Date: Tue, 8 Dec 2015 12:11:34 +0100 Subject: [PATCH] =str remove unused buffer pool --- .../main/scala/akka/stream/impl/io/InputStreamPublisher.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/io/InputStreamPublisher.scala b/akka-stream/src/main/scala/akka/stream/impl/io/InputStreamPublisher.scala index 5c5e58fabb..b4a4c37770 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/io/InputStreamPublisher.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/io/InputStreamPublisher.scala @@ -37,7 +37,6 @@ private[akka] class InputStreamPublisher(is: InputStream, bytesReadPromise: Prom import InputStreamPublisher._ - val buffs = new DirectByteBufferPool(chunkSize, maxBuffer) var eofReachedAtOffset = Long.MinValue var readBytesTotal = 0L @@ -87,6 +86,8 @@ private[akka] class InputStreamPublisher(is: InputStream, bytesReadPromise: Prom /** BLOCKING I/O READ */ def loadChunk() = try { + + // this is used directly by ByteString1C, therefore create a new one every time val arr = Array.ofDim[Byte](chunkSize) // blocking read