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

Some more dataflow cleanup

Browse source
This commit is contained in:
Viktor Klang 2010-08-23 16:06:52 +02:00
parent 03a557d0a0
commit 110780da03
1 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -70,11 +70,10 @@ object DataFlow {
self.timeout = TIME_OUT
private var readerFuture: Option[CompletableFuture[Any]] = None
def receive = {
case Get =>
dataFlow.value.get match {
case Some(value) => self reply value
case None => readerFuture = self.senderFuture
}
case Get => dataFlow.value.get match {
case Some(value) => self reply value
case None => readerFuture = self.senderFuture
}
case Set(v:T) => readerFuture.map(_ completeWithResult v)
case Exit => self.stop
}
@ -82,7 +81,7 @@ object DataFlow {
private[this] val in = actorOf(new In(this)).start
def <<(ref: DataFlowVariable[T]) = if(this.value.get.isEmpty) in ! Set(ref())
def <<(ref: DataFlowVariable[T]): Unit = if(this.value.get.isEmpty) in ! Set(ref())
def <<(value: T): Unit = if(this.value.get.isEmpty) in ! Set(value)