Skip to content

Commit

Permalink
v4.0.0-dev11
Browse files Browse the repository at this point in the history
增加事件处理结果在JVM中的扩展
  • Loading branch information
ForteScarlet committed Jan 19, 2024
1 parent ac2bcf3 commit 9cf335e
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions simbot-api/src/jvmTest/kotlin/DispatcherTests.kt
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ class DispatcherTests {
}

val concurrentMap =
flow.collectBy(this, Collectors.toConcurrentMap(Function.identity(), Function.identity()))
flow.collectBy(scope = this, collector = Collectors.toConcurrentMap(Function.identity(), Function.identity()))
val keySet = concurrentMap.keys
assertEquals(100, keySet.size)
repeat(100) {
Expand Down Expand Up @@ -137,8 +137,8 @@ class DispatcherTests {

val concurrentList =
flow.collectBy(
this,
Collector.of(
scope = this,
collector = Collector.of(
{ CopyOnWriteArrayList<Int>() },
{ l, v -> l.add(v) },
{ r1, r2 ->
Expand Down

0 comments on commit 9cf335e

Please sign in to comment.