- adapted to current Scala version

1 files changed, 15 insertions, 5 deletions

diff --git a/sources/examples/ComputeServer.scala b/sources/examples/ComputeServer.scala
index c3ea4907ad..034b996498 100644
--- a/sources/examples/ComputeServer.scala
+++ b/sources/examples/ComputeServer.scala
@@ -3,30 +3,40 @@ package examples;
 import concurrent._, concurrent.ops._;
 
 class ComputeServer(n: Int) {
+
   private trait Job {
     type t;
     def task: t;
-    def return(x: t): Unit;
+    def ret(x: t): Unit;
   }
 
   private val openJobs = new Channel[Job]();
 
   private def processor(i: Int): Unit = {
-    while (True) {
+    while (true) {
       val job = openJobs.read;
-      job.return(job.task)
+      Console.println("read a job");
+      job.ret(job.task)
     }
   }
+
   def future[a](def p: a): () => a = {
     val reply = new SyncVar[a]();
     openJobs.write{
       new Job {
 	type t = a;
 	def task = p;
-	def return(x: a) = reply.set(x);
+	def ret(x: a) = reply.set(x);
       }
     }
     () => reply.get
   }
-  replicate(1,n){processor}
+
+  spawn(replicate(0, n) { processor })
+}
+
+object Test with Executable {
+  val server = new ComputeServer(1);
+  val f = server.future(42);
+  Console.println(f())
 }