ATizik

class UploadFilesUsecase() {
    private val MAX_RETRIES = 3L

    private val scope = CoroutineScope(SupervisorJob() + Dispatchers.IO)

    private val atomic = atomic<Flow<File>?>(null)

    suspend fun uploadFiles(): Flow<File> {
        atomic.value?.let { return it }
        val channel = ConflatedBroadcastChannel<File>()

ATizik

class UploadFilesUsecase() : BaseObservable<UploadFilesUsecase.Listener>() {
    interface Listener {
        fun onFilesUploaded()
        fun onFilesUploadFailed()
    }

    private val MAX_RETRIES = 3
    private val mutex = Mutex()
    private val scope = CoroutineScope(SupervisorJob() + Dispatchers.IO)

ATizik

import androidx.fragment.app.Fragment
import androidx.fragment.app.viewModels
import androidx.lifecycle.*

interface MyViewModelInterface {
    val liveData: LiveData<String>
}

class MyViewModel:ViewModel(), MyViewModelInterface {
    override val liveData = MutableLiveData<String>()