adapted code to Scala 2 syntax in files src/exa...

adapted code to Scala 2 syntax in files src/examples/**/*.scala

1 files changed, 15 insertions, 14 deletions

diff --git a/docs/examples/oneplacebuffer.scala b/docs/examples/oneplacebuffer.scala
index 7fa2ae8dba..2d6277913c 100644
--- a/docs/examples/oneplacebuffer.scala
+++ b/docs/examples/oneplacebuffer.scala
@@ -1,45 +1,46 @@
-package examples;
+package examples
 
 object oneplacebuffer {
 
   import scala.concurrent._;
 
   class OnePlaceBuffer {
-    private val m = new MailBox() {};          // An internal mailbox
-    private case class Empty(), Full(x: Int);  // Types of messages we deal with
+    private val m = new MailBox() {}          // An internal mailbox
+    private case class Empty()                // Types of messages we deal with
+    private case class Full(x: Int)
 
-    m send Empty();                            // Initialization
+    m send Empty()                            // Initialization
 
     def write(x: Int): Unit = m receive {
       case Empty() =>
-        Console.println("put " + x);
+        Console.println("put " + x)
         m send Full(x)
     }
 
     def read: Int = m receive {
       case Full(x) =>
-        Console.println("get " + x);
-        m send Empty() ; x
+        Console.println("get " + x)
+        m send Empty(); x
     }
   }
 
   def main(args: Array[String]) = {
-    val buf = new OnePlaceBuffer;
-    val random = new java.util.Random();
+    val buf = new OnePlaceBuffer
+    val random = new java.util.Random()
 
     def producer(n: int): unit = {
-      Thread.sleep(random.nextInt(1000));
-      buf.write(n);
+      Thread.sleep(random.nextInt(1000))
+      buf.write(n)
       producer(n + 1)
     }
 
     def consumer: unit = {
-      Thread.sleep(random.nextInt(1000));
-      val n = buf.read;
+      Thread.sleep(random.nextInt(1000))
+      val n = buf.read
       consumer
     }
 
-    ops.spawn(producer(0));
+    ops.spawn(producer(0))
     ops.spawn(consumer)
   }