观察回调没有被Kotlin Coroutines流动和Livedata触发吗？

Question

我是Android开发的新手，并试图从各种示例项目中了解Coroutines和 livedata 。当用户输入用户名和密码时，我目前已经设置了一个函数来调用我的API。但是，在按下1按钮后，该应用似乎堵塞了，我无法将另一个API调用好像卡在待处理过程中一样。

这是我第一个用大量想法制作的Android应用程序，所以请让我知道我在哪里犯了错误！

活动：

binding.bLogin.setOnClickListener {
        val username = binding.etUsername.text.toString()
        val password = binding.etPassword.text.toString()
        viewModel.userClicked(username, password).observe(this, Observer {
            it?.let { resource ->
                when (resource.status) {
                    Status.SUCCESS -> {
                        print(resource.data)
                    }
                    Status.ERROR -> {
                        print(resource.message)
                    }
                    Status.LOADING -> {
                        // loader stuff
                    }
                }
            }
        })
 }

ViewModel：

fun userClicked(username: String, password: String) = liveData(dispatcherIO) {
    viewModelScope.launch {
        emit(Resource.loading(data = null))
        try {
            userRepository.login(username, password).apply {
                emit(Resource.success(null))
            }
        } catch (exception: Exception) {
            emit(Resource.error(exception.message ?: "Error Occurred!", data = null))
        }
    }
}

存储库：

@WorkerThread
suspend fun login(
    username: String,
    password: String
): Flow<Resource<String?>> {
    return flow {
        emit(Resource.loading(null))
        api.login(LoginRequest(username, password)).apply {
            this.onSuccessSuspend {
                data?.let {
                    prefs.apiToken = it.key
                    emit(Resource.success(null))
                }
            }
        }.onErrorSuspend {
            emit(Resource.error(message(), null))
        }.onExceptionSuspend {
            emit(Resource.error(message(), null))
        }
    }.flowOn(dispatcherIO)
}

API：

suspend fun login(@Body request: LoginRequest): ApiResponse<Auth>

Answer 1

您无需在 livedata 建造者中启动coroutine，它已经是 suppend ，因此您可以在此处调用 suppend 功能：

fun userClicked(username: String, password: String) = liveData(dispatcherIO) {
    emit(Resource.loading(data = null))
    try {
        userRepository.login(username, password).apply {
            emit(Resource.success(null))
        }
    } catch (exception: Exception) {
        emit(Resource.error(exception.message ?: "Error Occurred!", data = null))
    }
}

如果您想使用使用使用 flow 您可以使用 aslivedata 函数：

fun userClicked(username: String, password: String): LiveData<Resource<String?>> {
    return userRepository.login(username, password).asLiveData()
}

但是我不建议将 livedata 和 flow 流中混合。我建议仅使用 Flow 。

仅使用 flow ：

// In ViewModel:

fun userClicked(username: String, password: String): Flow<Resource<String?>> {
    return userRepository.login(username, password)
}

// Activity

binding.bLogin.setOnClickListener {
        val username = binding.etUsername.text.toString()
        val password = binding.etPassword.text.toString()
        lifecycleScope.launch {
            viewModel.userClicked(username, password).collect { resource ->
                when (resource.status) {
                    Status.SUCCESS -> {
                        print(resource.data)
                    }
                    Status.ERROR -> {
                        print(resource.message)
                    }
                    Status.LOADING -> {
                        // loader stuff
                    }
                }
            }
        }
    }

删除暂停关键字从登录 repository 中的功能。

lifecyclescope docs 。