diff options
Diffstat (limited to 'core/src/test/kotlin/ca')
| -rw-r--r-- | core/src/test/kotlin/ca/allanwang/kau/kotlin/ZipTest.kt | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/core/src/test/kotlin/ca/allanwang/kau/kotlin/ZipTest.kt b/core/src/test/kotlin/ca/allanwang/kau/kotlin/ZipTest.kt index 4a04142..7eeffaf 100644 --- a/core/src/test/kotlin/ca/allanwang/kau/kotlin/ZipTest.kt +++ b/core/src/test/kotlin/ca/allanwang/kau/kotlin/ZipTest.kt @@ -24,8 +24,7 @@ class ZipTest { val latch = CountDownLatch(1) val rnd = Random() (0..10).map { - { - callback: ZipCallback<Int> -> + { callback: ZipCallback<Int> -> doAsync { val sleepTime = rnd.nextInt(100) + 200L p("Task $it will sleep for ${sleepTime}ms") @@ -35,8 +34,7 @@ class ZipTest { callback(it) }; Unit } - }.zip(-1) { - results -> + }.zip(-1) { results -> val finish = System.currentTimeMillis() println("Results ${results.contentToString()} received in ${finish - start}ms at $finish") assertTrue((0..10).toList().toTypedArray().contentEquals(results), "Basic zip results do not match") |