summaryrefslogtreecommitdiff
path: root/example/src/main/scala/example/main.scala
diff options
context:
space:
mode:
Diffstat (limited to 'example/src/main/scala/example/main.scala')
-rw-r--r--example/src/main/scala/example/main.scala27
1 files changed, 17 insertions, 10 deletions
diff --git a/example/src/main/scala/example/main.scala b/example/src/main/scala/example/main.scala
index a8470a2..473cce0 100644
--- a/example/src/main/scala/example/main.scala
+++ b/example/src/main/scala/example/main.scala
@@ -21,7 +21,7 @@ object Main extends App {
val p2 = async {
var a = 0
- while ({a = await(ch.take()); a} < 5) {
+ while ({ a = await(ch.take()); a } < 5) {
println(a)
}
}
@@ -53,7 +53,7 @@ object SelectTest extends App {
val r = async {
await(Channel.select(ch, t)) match {
- case (`t`, _) => println("timeout")
+ case (`t`, _) => println("timeout")
case (`ch`, value: Int) => await(out.put(value.toString)),
}
await(out.take())
@@ -63,7 +63,6 @@ object SelectTest extends App {
}
-
object Select2Test extends App {
val ch = Channel[Int](0)
@@ -78,18 +77,26 @@ object Select2Test extends App {
// }
Channel.select2(
- t -> {u: Unit => println("timeout")},
- ch -> {v: Int => println(v); out.put(v.toString); ()}
+ t -> { u: Unit =>
+ println("timeout")
+ },
+ ch -> { v: Int =>
+ println(v); out.put(v.toString); ()
+ }
)
val r = async {
- await(Channel.select2(
- t -> {u: Unit => println("timeout")},
- out -> {s: String => println(s)}
- ))
+ await(
+ Channel.select2(
+ t -> { u: Unit =>
+ println("timeout")
+ },
+ out -> { s: String =>
+ println(s)
+ }
+ ))
}
Await.result(r, 10.seconds)
println(r)
-
}