summaryrefslogtreecommitdiff
path: root/shared/src/test/scala/escale/SimpleTest.scala
diff options
context:
space:
mode:
authorJakob Odersky <jakob@odersky.com>2018-11-13 21:08:51 -0800
committerJakob Odersky <jakob@odersky.com>2018-11-13 21:08:51 -0800
commit3c59af848c37e1530876e95f7321c8757855d030 (patch)
tree12599d8111377f28f36e659acd9853cd020aa908 /shared/src/test/scala/escale/SimpleTest.scala
parent4b672ab5fc91b2b3c13e23f130f810b79ab7c928 (diff)
downloadescale-3c59af848c37e1530876e95f7321c8757855d030.tar.gz
escale-3c59af848c37e1530876e95f7321c8757855d030.tar.bz2
escale-3c59af848c37e1530876e95f7321c8757855d030.zip
Various enhancements
- add select support for takes - add syntax sugar - add support for JS and Native
Diffstat (limited to 'shared/src/test/scala/escale/SimpleTest.scala')
-rw-r--r--shared/src/test/scala/escale/SimpleTest.scala47
1 files changed, 47 insertions, 0 deletions
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