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 c6cf814 commit 905fe0aCopy full SHA for 905fe0a
kotlinx-coroutines-core/common/test/flow/channels/ChannelFlowTest.kt
@@ -227,13 +227,14 @@ class ChannelFlowTest : TestBase() {
227
fun testDispatchesToDifferentDispatcherWhenCollected() = runTest {
228
expect(1)
229
val myFlow = flow<Int> {
230
- finish(4)
+ expect(4)
231
}.flowOn(wrapperDispatcher())
232
launch(start = CoroutineStart.UNDISPATCHED) {
233
expect(2)
234
myFlow.collectLatest {
235
expectUnreached()
236
}
237
+ finish(5)
238
239
expect(3)
240
0 commit comments