From acc28f58202b5382a3e42c28a2f5261d111b2d9b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Endre=20S=C3=A1ndor=20Varga?= Date: Tue, 5 May 2015 13:55:00 +0200 Subject: [PATCH] =str #17308: Don't do blocking prefetch before subscription in fileSource --- .../scala/akka/stream/io/impl/SynchronousFilePublisher.scala | 1 - 1 file changed, 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/io/impl/SynchronousFilePublisher.scala b/akka-stream/src/main/scala/akka/stream/io/impl/SynchronousFilePublisher.scala index 436a086fbe..967cd045cf 100644 --- a/akka-stream/src/main/scala/akka/stream/io/impl/SynchronousFilePublisher.scala +++ b/akka-stream/src/main/scala/akka/stream/io/impl/SynchronousFilePublisher.scala @@ -47,7 +47,6 @@ private[akka] class SynchronousFilePublisher(f: File, bytesReadPromise: Promise[ try { raf = new RandomAccessFile(f, "r") // best way to express this in JDK6, OpenOption are available since JDK7 chan = raf.getChannel - readAndSignal(initialBuffer) } catch { case ex: Exception ⇒ onErrorThenStop(ex)