@Test
    fun testStateFlow() {
        runBlocking {
            launch(GlobalScope.coroutineContext) {
                val state = MutableStateFlow<Int>(1)
                state
                        .onEach { log("First ${Thread.currentThread().name}") }
                        .flowOn(newSingleThreadContext("Thread1"))
                        .onEach { log("Second ${Thread.currentThread().name}") }
                        .flowOn(newSingleThreadContext("Thread2"))
                        .onEach { log("Third ${Thread.currentThread().name}") }
                        .launchIn(GlobalScope)
                log("Emit ${Thread.currentThread().name}")
                state.value = 1
                delay(100)
            }
        }
    }

    fun log(s: String) {
        System.out.println(s)
    }

Emit main @coroutine#2
First Thread1 @coroutine#5
Second Thread2 @coroutine#4
Third DefaultDispatcher-worker-2 @coroutine#3