File tree Expand file tree Collapse file tree 1 file changed +17
-18
lines changed Expand file tree Collapse file tree 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 {
380380 assertEquals(sum, range.sum)
381381 }
382382
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+ }
401400
402401 test(" future collection: awaitAll*" ) {
403402 Async .blocking:
You can’t perform that action at this time.
0 commit comments