raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

clean up IO tests based on feedback

Browse source
This commit is contained in:
Derek Williams 2012-01-02 22:10:00 -07:00
parent 2f7b594e28
commit 8894772282
1 changed files with 5 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-actor-tests/src/test/scala/akka/actor/IOActor.scala
View file

@ -14,7 +14,7 @@ object IOActorSpec {
class SimpleEchoServer(host: String, port: Int, started: TestLatch) extends Actor {
implicit val system = context.system
import context.system
IO listen (host, port)
@ -26,13 +26,7 @@ object IOActorSpec {
case IO.NewClient(server) ⇒
val socket = server.accept()
state(socket) flatMap { _ ⇒
IO repeat {
IO.takeAny map { bytes ⇒
socket write bytes
}
}
}
state(socket) flatMap (_ ⇒ IO repeat (IO.takeAny map socket.write))
case IO.Read(socket, bytes) ⇒
state(socket)(IO Chunk bytes)
@ -46,7 +40,7 @@ object IOActorSpec {
class SimpleEchoClient(host: String, port: Int) extends Actor {
implicit val system = context.system
import context.system
val socket = IO connect (host, port)
@ -91,7 +85,7 @@ object IOActorSpec {
// Basic Redis-style protocol
class KVStore(host: String, port: Int, started: TestLatch) extends Actor {
implicit val system = context.system
import context.system
val state = IO.IterateeRef.Map.sync[IO.Handle]()
@ -157,7 +151,7 @@ object IOActorSpec {
class KVClient(host: String, port: Int) extends Actor {
implicit val system = context.system
import context.system
val socket = IO connect (host, port)