From e853a1d2ae782c51786b1eee4cd6429d538ed8b8 Mon Sep 17 00:00:00 2001
From: Johannes Rudolph <johannes_rudolph@gmx.de>
Date: Mon, 21 Jan 2013 18:26:56 +0100
Subject: [PATCH] fix race condition when trying to assert closed channel on
 the server side

---
 akka-io/src/test/scala/akka/io/TcpConnectionSpec.scala | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/akka-io/src/test/scala/akka/io/TcpConnectionSpec.scala b/akka-io/src/test/scala/akka/io/TcpConnectionSpec.scala
index 01f04fb147..79dbf8ec0c 100644
--- a/akka-io/src/test/scala/akka/io/TcpConnectionSpec.scala
+++ b/akka-io/src/test/scala/akka/io/TcpConnectionSpec.scala
@@ -161,6 +161,8 @@ class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms")
       closeCommander.expectMsg(Closed)
       assertThisConnectionActorTerminated()
 
+      nioSelector.select(2000)
+
       val buffer = ByteBuffer.allocate(1)
       serverSideChannel.read(buffer) must be(-1)
     }
@@ -207,6 +209,7 @@ class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms")
       connectionHandler.expectNoMsg(100.millis) // not yet
 
       val buffer = ByteBuffer.allocate(1)
+      nioSelector.select(2000)
       serverSideChannel.read(buffer) must be(-1)
       serverSideChannel.close()