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

Exit is bad mkay

Browse source
This commit is contained in:
Viktor Klang 2010-08-20 12:14:41 +02:00
parent 9c6e8333b7
commit 1e2fe00aff
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-core/src/main/scala/dataflow/DataFlowVariable.scala
View file

@ -36,7 +36,7 @@ import se.scalablesolutions.akka.dispatch.CompletableFuture
private class IsolatedEventBasedThread(body: => Unit) extends Actor {
def receive = {
case Start => body
case Exit => exit
case Exit => self.stop
}
}
@ -46,7 +46,7 @@ import se.scalablesolutions.akka.dispatch.CompletableFuture
private class ReactiveEventBasedThread[A <: AnyRef, T <: AnyRef](body: A => T)
extends Actor {
def receive = {
case Exit => exit
case Exit => self.stop
case message => self.reply(body(message.asInstanceOf[A]))
}
}
@ -74,7 +74,7 @@ import se.scalablesolutions.akka.dispatch.CompletableFuture
dataFlow.blockedReaders.clear
} else throw new DataFlowVariableException(
"Attempt to change data flow variable (from [" + dataFlow.value.get + "] to [" + v + "])")
case Exit => exit
case Exit => self.stop
}
}
@ -87,7 +87,7 @@ import se.scalablesolutions.akka.dispatch.CompletableFuture
if (ref.isDefined) self.reply(ref.get)
else readerFuture = self.senderFuture.asInstanceOf[Option[CompletableFuture[T]]]
case Set(v:T) => if (readerFuture.isDefined) readerFuture.get.completeWithResult(v)
case Exit => exit
case Exit => self.stop
}
}