SampleRespository.kt

class UserRepository(private val responseHandler: ResponseHandler) {

    suspend fun stimulateSocketTimeout() = flow {

        //stimulate a network call
        kotlinx.coroutines.delay(500)
        emit(
            //stimulate a failed network response
            if (false) {


                responseHandler
                    .handleSuccess("This should be api response")


            } else {
                Resource.Error(
                    CustomMessages.NO_INTERNET
                )


            }
        )
    }.flowOn(Dispatchers.IO).catch { e ->
        e.printStackTrace()
        emit(

            Resource.Error(
               CustomMessages.SOMETHING_WENT_WRONG
            )

        )


    }
}