From dccadd95f9199e87f9be6996d206a32a42ac687f Mon Sep 17 00:00:00 2001
From: Patrik Nordwall <patrik.nordwall@gmail.com>
Date: Tue, 29 Apr 2014 16:51:46 +0200
Subject: [PATCH] =str #15065 Avoid use of reflection in TcpConnectionStream

* Fixes #15065
---
 .../src/main/scala/akka/stream/io/TcpConnectionStream.scala | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/akka-stream/src/main/scala/akka/stream/io/TcpConnectionStream.scala b/akka-stream/src/main/scala/akka/stream/io/TcpConnectionStream.scala
index 5c21cd279b..4c0e9b6f20 100644
--- a/akka-stream/src/main/scala/akka/stream/io/TcpConnectionStream.scala
+++ b/akka-stream/src/main/scala/akka/stream/io/TcpConnectionStream.scala
@@ -58,7 +58,7 @@ private[akka] abstract class TcpStreamActor(val settings: MaterializerSettings)
 
   }
 
-  val tcpOutputs = new DefaultOutputTransferStates {
+  object tcpOutputs extends DefaultOutputTransferStates {
     private var closed: Boolean = false
     private var pendingDemand = true
     override def isClosed: Boolean = closed
@@ -79,7 +79,7 @@ private[akka] abstract class TcpStreamActor(val settings: MaterializerSettings)
     override def demandAvailable: Boolean = pendingDemand
   }
 
-  val writePump = new Pump {
+  object writePump extends Pump {
     lazy val NeedsInputAndDemand = primaryInputs.NeedsInput && tcpOutputs.NeedsDemand
     override protected def transfer(): TransferState = {
       var batch = ByteString.empty
@@ -92,7 +92,7 @@ private[akka] abstract class TcpStreamActor(val settings: MaterializerSettings)
     override protected def pumpContext: ActorRefFactory = context
   }
 
-  val readPump = new Pump {
+  object readPump extends Pump {
     lazy val NeedsInputAndDemand = tcpInputs.NeedsInput && primaryOutputs.NeedsDemand
     override protected def transfer(): TransferState = {
       primaryOutputs.enqueueOutputElement(tcpInputs.dequeueInputElement())