FlowIntermediatePperators.kt

import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.launch

suspend fun main(): Unit = coroutineScope {

    val simpleFlow = flow {
        delay(1500)
        emit(1)
        delay(1500)
        emit(2)
//        throw Exception("Network Exception")
        delay(1500)
        emit(3)
    }

    launch {
        simpleFlow.onStart {
            println("Start block where we can update the UI like starting the progressbar ")
        }.onEach { item ->
            val result =  item + 100
            println("Each item received $result")
        }.onCompletion { cause ->
            println("The flow emission is done. Stop the progressbar $cause")
            /**
             * if u comment this line  throw Exception("Network Exception")
             * output : The flow emission is done. Stop the progressbar java.lang.Exception: Network Exception
             * otherwise
             * output : The flow emission is done. Stop the progressbar null
             */
        }.collect {}
    }
}