File tree 1 file changed +17
-18
lines changed
1 file changed +17
-18
lines changed Original file line number Diff line number Diff line change @@ -380,24 +380,23 @@ class FutureBehavior extends munit.FunSuite {
380
380
assertEquals(sum, range.sum)
381
381
}
382
382
383
- // crashing atm
384
- // test("mutable collector") {
385
- // Async.blocking:
386
- // val range = (0 to 10)
387
- // val futs = range.map(i => Future { sleep(i * 100); i })
388
- // val collector = Future.MutableCollector(futs*)
389
-
390
- // for i <- range do
391
- // val r = Future { i }
392
- // Future:
393
- // sleep(i * 200)
394
- // collector += r
395
-
396
- // var sum = 0
397
- // for i <- range do sum += collector.results.read().right.get.await
398
- // for i <- range do sum += collector.results.read().right.get.await
399
- // assertEquals(sum, 2 * range.sum)
400
- // }
383
+ test(" mutable collector" ) {
384
+ Async .blocking:
385
+ val range = (0 to 10 )
386
+ val futs = range.map(i => Future { sleep(i * 100 ); i })
387
+ val collector = Future .MutableCollector (futs* )
388
+
389
+ for i <- range do
390
+ val r = Future { i }
391
+ Future :
392
+ sleep(i * 200 )
393
+ collector += r
394
+
395
+ var sum = 0
396
+ for i <- range do sum += collector.results.read().right.get.await
397
+ for i <- range do sum += collector.results.read().right.get.await
398
+ assertEquals(sum, 2 * range.sum)
399
+ }
401
400
402
401
test(" future collection: awaitAll*" ) {
403
402
Async .blocking:
You can’t perform that action at this time.
0 commit comments