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 9c77405 commit a9bda03Copy full SHA for a9bda03
channel-event-bus/src/jvmTest/kotlin/com/hoc081098/channeleventbus/ChannelEventBusJvmTest.kt
@@ -23,7 +23,7 @@ class ChannelEventBusJvmTest {
23
fun flatMapLatest_Works(): Unit = runBlocking(Dispatchers.IO) {
24
val bus = ChannelEventBus(ChannelEventBusLogger.noop())
25
val flow = interval(initialDelay = Duration.ZERO, period = 11.milliseconds)
26
- .flowOn(Executors.newScheduledThreadPool(2).asCoroutineDispatcher())
+ .flowOn(Dispatchers.IO)
27
.take(10)
28
.flatMapLatest { bus.receiveAsFlow(TestEventInt) }
29
.take(50)
0 commit comments