We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 079d72a commit 09a0ecaCopy full SHA for 09a0eca
src/test/scala/gopher/channels/FlowTerminationSuite.scala
@@ -52,6 +52,25 @@ class FlowTerminationSuite extends FunSuite
52
53
}
54
55
+ test("not propagate signals after exit") {
56
+
57
+ import gopherApi._
58
+ val channel = makeChannel[Int](100)
59
+ var sum = 0
60
+ val f = select.forever{
61
+ case x: channel.read => sum += x
62
+ CurrentFlowTermination.exit(())
63
+ //TODO: implement syntax
64
+ //select.shutdown()
65
+ }
66
+ val f2 = channel.awrite(1)
67
+ Await.result(f, 1 second)
68
+ assert(sum == 1)
69
+ val f3 = channel.awrite(2)
70
+ Thread.sleep(1000)
71
72
73
74
75
val gopherApi = CommonTestObjects.gopherApi
76
0 commit comments