MVVM with Kotlin Flow

ExampleActivity.kt

onCreate() {
  val viewModel = ... //initialize your view model
  
  viewModel.getData()
  viewModel.data.observe(this, Observer {
    //do operations based on the value
  })
}

RepositoryFlow.kt

fun getData(): Flow<Data> = flow {
  //do network calls
  emit(data)
}.flowOn(Dispatcher.IO)

ViewModelFlow.kt

val data: LiveData<Data> = MutableLiveData()
 
 fun getData() {
   data = repository.getData().onStart {
     //do something
   }.asLiveData(viewModelScope.coroutineContext)
 }