Dataflow Futures

gistfile1.scala

import actors.Futures

class DataflowFuture[A] private(f : => A) {
  val future = Futures.future(f)
}

object DataflowFuture {
  def apply[A](f : => A) = new DataflowFuture[A](f)

  implicit def dataflowFutureToVal[A](df : DataflowFuture[A]) : A = df.future.apply()
}