=str remove unused buffer pool

This commit is contained in:
Martynas Mickevicius 2015-12-08 12:11:34 +01:00
parent df3c0e32b6
commit 511a55f562

View file

@ -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