SharedFlowTesting.kt

@Test
fun sharedFlowSampleTest() = runTest {
    val values = mutableListOf<Int>()
    val sharedFlow = MutableSharedFlow<Int>()

    val job = launch { 
      sharedFlow.toList(values) 
    }
    advanceUntilIdle()

    sharedFlow.emit(1)
    sharedFlow.emit(2)
    sharedFlow.emit(3)

    job.cancel()

    assertEquals(listOf(1, 2, 3), values)
}

@Test
fun sharedFlowSampleTest2() = runTest {
    val values = mutableListOf<Int>()
    val sharedFlow = MutableSharedFlow<Int>()

    val job = launch(UnconfinedTestDispatcher()) { 
      sharedFlow.toList(values) 
    }

    sharedFlow.emit(1)
    sharedFlow.emit(2)
    sharedFlow.emit(3)

    job.cancel()

    assertEquals(listOf(1, 2, 3), values)
}