Poor Man's Dataflow

gistfile1.scala

import actors.Futures.future

object PoorMansDataflow {
  def main(args : Array[String]) {

    // ....

    val pastSales = future(db.getTotalSales)
    val todaysSales = future(input.map(parseReport(_)).sumBy(_.totalSold))

    printf("Total sales: %d\n", pastSales.apply() + todaysSales.apply())
  }

}