Emit LiveData для обновления пользовательского интерфейса между последующими вызовами метода приостановки - PullRequest
Новая
       29

Emit LiveData для обновления пользовательского интерфейса между последующими вызовами метода приостановки

1 голос
/ 14 июня 2019

Я пытаюсь обновить интерфейс между вызовами метода suspend, когда получаю результаты от них.Например, вот мой класс ViewModel.Методы a (), b () и c () являются методами приостановки. 

class MainViewModel : ViewModel() {

    lateinit var userLiveData: LiveData<String>
    var repo = MainRepo()

     fun startTest() {
          userLiveData = liveData {
             var a =  repo.a()
             System.out.println("@@@@@@@@ $a")
             emit(a)
             var b = repo.b(a)
             System.out.println("@@@@@@@@ $b")
             emit(b)
             var c = repo.c(b)
             System.out.println("@@@@@@@@ $c")
             emit(c)
         }
    }
}

, и это мой класс Activity, где я наблюдаю за LiveData 

viewModel = ViewModelProviders.of(this).get(MainViewModel::class.java)
        viewModel.startTest()
        viewModel.userLiveData.observe(this, Observer {
            text.text = it
        })

и классом Repo.

class MainRepo {

    suspend fun a(): String{
        delay(1000)
        return "A"
    }
    suspend fun b(a: String): String{
        delay(5000)
        return a + "B"
    }
    suspend fun c(b: String): String{
        return b + "-C"
    }
}

Мой вопрос: как я могу обновить пользовательский интерфейс с результатами после того, как я позвоню repo.a() или repo.b() или repo.c().Заранее спасибо.

1 Ответ

1 голос
/ 15 июня 2019

Этого можно добиться с помощью изменяемых данных в реальном времени с сопрограммами. Кроме того, функция приостановки может быть вызвана только сопрограммой или другой функцией приостановки. Я проверил приведенный ниже код. Надеюсь, это поможет.

Ваша модель представления: 

val userLiveData = MutableLiveData<Map<String, String>>()

fun startTest() {
    viewModelScope.launch {
        var newVal = itemRepository.a()
        userLiveData.value = mapOf("responseTime" to newVal)
        newVal = itemRepository.b(newVal)
        userLiveData.value = mapOf("downloadSpeed" to newVal)
        newVal = itemRepository.c(newVal)
        userLiveData.value = mapOf("uploadSpeed" to newVal)
    }
}

Активность: 

itemViewModel.userLiveData.observe(viewLifecycleOwner, Observer { result ->
            result.get("responseTime")?.let {
                println("setting textField Response as :" +result["responseTime"])
            }
            result.get("downloadSpeed")?.let {
                println("setting textField2 Download Speed is :" +result["downloadSpeed"])
            }
            result.get("uploadSpeed")?.let {
                println("setting textField3 Upload Speed is :" +result["uploadSpeed"])
            }
        })
    itemViewModel.startTest()

Repo: 

class MainRepo {

    suspend fun a(): String{
        delay(1000)
        return "A"
    }
    suspend fun b(a: String): String{
        delay(5000)
        return a + "B"
    }
    suspend fun c(b: String): String{
        return b + "-C"
    }
}

Выход: 

setting textField Response as :A
setting textField2 Download Speed is :AB
setting textField3 Upload Speed is :AB-C
...