Collect the numbered chunks for reassembly

Reducer.scala

import scala.actors.Actor.self
import scala.actors.remote.RemoteActor.{ register, alive }
import scala.actors.Actor
import scala.collection.immutable.TreeMap
import scala.collection.mutable.Map

object Reducer {
    def main(args: Array[String]) {
        println("Reducer running")

        val actor = new Actor {
            def act {
                alive(System.getProperty("port").toInt)
                register('reducer, self)

                var results = System.getProperty("results").toInt
                println("Expecting " + results + " result(s)")

                var map = TreeMap[Int, String]()
                while (results > 0) {
                    receive {
                        case m: Map[Int, String] ⇒ println("Received " + m); map ++= m; results -= 1
                    }
                }

                println("Results " + map)
            }
        }

        actor.start
    }
}