如何 return 从协程范围取值

Question

有没有办法 return 从协程范围获取值？例如像这样：

suspend fun signUpUser(signUpData : SignUpUserRequest) : User {

CoroutineScope(Dispatchers.IO).launch() {

        val response = retrofitInstance.socialSignUP(signUpData)
        if (response.success) {
            obj = response.data
        } else {
                obj = response.message
        }
    }.invokeOnCompletion {
        obj = response.message
    }

    return obj
}

问题是一旦调用了 signupUser 函数，return obj suspend 语句运行马上，而不是响应值..它不是运行ning 顺序，我所期望的是第一个响应，然后函数 return obj 但它没有发生。为什么？

我试过运行阻塞，它达到了目的，但是有没有更好的方法来完成同样的任务而不运行阻塞？或者可以吗？

提前致谢！

Answer 1

您可以使用 withContext 函数来运行后台线程中的代码和 return 一些结果：

suspend fun signUpUser(signUpData : SignUpUserRequest): User = withContext(Dispatchers.IO) {    
    val response = retrofitInstance.socialSignUP(signUpData)
    if (response.success) response.data else response.message
}

Answer 2

如果您需要运行并行工作，那么您可以使用 coroutineScope 或 async 协程构建函数。但是，在您的情况下，您只有一个请求，因此它可能是 sequantial。如前一个答案所述，您可以使用 withContext。这是来自 docs 的小解释：

Calls the specified suspending block with a given coroutine context, suspends until it completes, and returns the result.

suspend fun getUser(signUpData: SignUpUserRequest): User = withContext(Dispatchers.IO) {
    // do your network request logic here and return the result
}

请注意，当您使用带有函数的表达式主体时，请始终尝试显式注释 return 类型。

编辑

协程使用常规 Kotlin 语法来处理异常：try/catch 或内置辅助函数，如 runCatching（使用 try/catch内部）。当心总是会抛出未捕获的异常。但是，不同的协程构建器以不同的方式处理异常。阅读总是好的 official documentation or other sources (like this).

Answer 3

在 Google 代码实验室 "Load and display images from the Internet" 中，有一个使用 MutableLiveData 的很好且非常优雅的示例。

大纲：

您使用 LiveData（内部）和 MutableLiveData（外部）制作了一个 ViewModel
现在您可以直接在视图、片段或活动中使用数据

好处是此数据是生命周期感知的，您可以将返回值与观察者一起使用。

class OverviewViewModel : ViewModel() {

    enum class MarsApiStatus { LOADING, ERROR, DONE }

    private val _status = MutableLiveData<MarsApiStatus>()
    val status: LiveData<MarsApiStatus> = _status

    private val _photos = MutableLiveData<List<MarsPhoto>>()
    val photos: LiveData<List<MarsPhoto>> = _photos

    /**
     * Call getMarsPhotos() on init so we can display status immediately.
     */
    init {
        getMarsPhotos()
    }

    /**
     * Gets Mars photos information from the Mars API Retrofit service and updates the
     * [MarsPhoto] [List] [LiveData].
     */
    private fun getMarsPhotos() {
        viewModelScope.launch {
            _status.value = MarsApiStatus.LOADING
            Log.d(TAG, "loading")
            try {
                _photos.value = MarsApi.retrofitService.getPhotos()
                _status.value = MarsApiStatus.DONE
                Log.d(TAG, "done")
            } catch (e: Exception) {
                _status.value = MarsApiStatus.ERROR
                _photos.value = listOf()
                Log.d(TAG, "error")
            }
        }
    }
}

您可以通过观察或直接在如下视图中使用它们来使用状态或照片值：

    <androidx.recyclerview.widget.RecyclerView
        android:id="@+id/photos_grid"
        android:layout_width="0dp"
        android:layout_height="0dp"
        app:layoutManager="androidx.recyclerview.widget.GridLayoutManager"
        app:layout_constraintBottom_toBottomOf="parent"
        app:layout_constraintLeft_toLeftOf="parent"
        app:layout_constraintRight_toRightOf="parent"
        app:layout_constraintTop_toTopOf="parent"
        app:listData="@{viewModel.photos}"
        app:spanCount="2"
        tools:itemCount="16"
        tools:listitem="@layout/grid_view_item" />

...在您“注册”并连接 f.ex 中的所有内容之后。关于片段，像这样：

override fun onCreateView(
    inflater: LayoutInflater, container: ViewGroup?,
    savedInstanceState: Bundle?
): View? {

    try {
        val binding = FragmentOverviewBinding.inflate(inflater)
        //val binding = GridViewItemBinding.inflate(inflater)

        // Allows Data Binding to Observe LiveData with the lifecycle of this Fragment
        binding.lifecycleOwner = this

        // Giving the binding access to the OverviewViewModel
        binding.viewModel = viewModel

        binding.photosGrid.adapter = PhotoGridAdapter()

        return binding.root
    } catch (e: Exception) {
        Log.e("OverviewFragment", "${e.localizedMessage}")
    }
    return null
}

如何 return 从协程范围取值

How to return value from coroutine scope

android

kotlin

kotlin-coroutines

coroutinescope

编辑