From 3c59af848c37e1530876e95f7321c8757855d030 Mon Sep 17 00:00:00 2001
From: Jakob Odersky <jakob@odersky.com>
Date: Tue, 13 Nov 2018 21:08:51 -0800
Subject: Various enhancements

- add select support for takes
- add syntax sugar
- add support for JS and Native
---
 shared/src/test/scala/escale/SimpleTest.scala | 47 +++++++++++++++++++++++++++
 1 file changed, 47 insertions(+)
 create mode 100644 shared/src/test/scala/escale/SimpleTest.scala

(limited to 'shared/src/test/scala/escale/SimpleTest.scala')

diff --git a/shared/src/test/scala/escale/SimpleTest.scala b/shared/src/test/scala/escale/SimpleTest.scala
new file mode 100644
index 0000000..6f52b06
--- /dev/null
+++ b/shared/src/test/scala/escale/SimpleTest.scala
@@ -0,0 +1,47 @@
+package escale
+
+import scala.async.Async.{async, await}
+import utest._
+import scala.concurrent.ExecutionContext.Implicits.global
+
+object SimpleTest extends TestSuite {
+  val tests = Tests{
+    "put and take" - {
+      val ch = Channel[Int](0)
+      val p1 = async{
+        await(ch.put(1))
+        await(ch.put(2))
+        await(ch.put(3))
+        await(ch.put(4))
+      }
+      async{
+        await(ch.take())
+        await(ch.take())
+        await(ch.take())
+        await(ch.take())
+      }
+      p1
+    }
+    "put and take while"- {
+      val ch = Channel[Int](0)
+      ch.put(1)
+
+      val p1 = async {
+        await(ch.put(2))
+        await(ch.put(3))
+        await(ch.put(4))
+        await(ch.put(5))
+      }
+
+      val p2 = async {
+        var sum = 0
+        var a = 0
+        while ({ a = await(ch.take()); a } < 5) {
+          sum += a
+        }
+        assert(sum == 10)
+      }
+      p2
+    }
+  }
+}
\ No newline at end of file
-- 
cgit v1.2.3