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

renamed dataflow variable file

Browse source
This commit is contained in:
Jonas Bonér 2010-11-24 17:49:06 +01:00
parent 2ba20cf5f1
commit 96011a026e
1 changed files with 11 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

14
akka-actor/src/main/scala/akka/dataflow/DataFlowVariable.scala → akka-actor/src/main/scala/akka/dataflow/DataFlow.scala
View file

@ -157,8 +157,18 @@ object DataFlow {
class DataFlowStream[T <: Any] extends Seq[T] {
private[this] val queue = new LinkedBlockingQueue[DataFlowVariable[T]]
def <<<(ref: DataFlowVariable[T]) = queue.offer(ref)
def next: DataFlowVariable[T] = queue.take
//==== Java API ====
def offer(ref: DataFlowVariable[T]) = <<<(ref)
def offer(value: T) = <<<(value)
def take(): T = apply()
//==== Scala API ====
def <<<(ref: DataFlowVariable[T]) = queue.offer(ref)
def <<<(value: T) = {
val ref = new DataFlowVariable[T]
ref << value
@ -172,8 +182,6 @@ object DataFlow {
result
}
def take: DataFlowVariable[T] = queue.take
//==== For Seq ====
def length: Int = queue.size