KwabenBerko

@OptIn(ExperimentalCoroutinesApi::class)
class JobStatusComponentTest {
    @Test
    fun `should call refresh function only once`() = runTest {
        val jobs = mutableListOf<Job>()
        val component = JobStatusComponent(scope = this)

        repeat(10){
            jobs += launch { component.refresh() }
        }

KwabenBerko

class JobStatusComponent(private val scope: CoroutineScope): Component {
    var job: Job? = null
    var refreshesCount: Int = 0
        private set

    override suspend fun refresh() {
        if (job?.isActive == false){
            job = scope.launch {
                try {
                    delay(1L)

KwabenBerko

@OptIn(ExperimentalCoroutinesApi::class)
class MutexEnabledComponentTest {
    @Test
    fun `should call refresh function only once`() = runTest {
        val jobs = mutableListOf<Job>()
        val component = MutexEnabledComponent()

        repeat(10){
            jobs += launch { component.refresh() }
        }

KwabenBerko

@OptIn(ExperimentalCoroutinesApi::class)
class PlainComponentTest {
    @Test
    fun `should call refresh function multiple times`() = runTest {
        val jobs = mutableListOf<Job>()
        val component = PlainComponent()

        repeat(10){
            jobs += launch { component.refresh() }
        }

KwabenBerko

class MutexEnabledComponent: Component {
    private val mutex = Mutex()
    var refreshesCount: Int = 0
        private set

    override suspend fun refresh() {
        if (!mutex.isLocked){
            mutex.withLock {
                delay(1L) // Delay to simulate a long running operation
                refreshesCount++

KwabenBerko

class PlainComponent: Component {
    var refreshesCount: Int = 0
        private set

    override suspend fun refresh(){
        delay(1L) // Delay to simulate a long running operation
        refreshesCount++
    }
}

KwabenBerko

interface Component {
    suspend fun refresh()
}

KwabenBerko

class FlowViewModelTest {

    @get:Rule
    val rule = MainCoroutineRule()

    private companion object {
        val CHARACTERS = listOf('A', 'B', 'C')
    }

    private val repository = mock<CharacterRepository>().apply {

KwabenBerko

class MainCoroutineRule : TestWatcher() {

    private val testDispatcher = TestCoroutineDispatcher()

    override fun starting(description: Description?) {
        Dispatchers.setMain(testDispatcher)
    }

    fun setup(setupBody: () -> Unit){
        testDispatcher.pauseDispatcher()

KwabenBerko

@Composable
fun ConverterScreen(
    navController: NavController,
    viewModel: ConverterViewModel
) {

    val scaffoldState = rememberScaffoldState()
    val viewState by viewModel.viewState.collectAsState()
    val viewEffects by viewModel.viewEffects.collectAsState(initial = null)