将多个流收集为一个

Question

我正在嵌套启动{}的流程中从数据存储区收集数据。

   viewLifecycleOwner.lifecycleScope.launchWhenStarted { 
                launch { 
                    DataStore.userName.collect {
                       // it emits string value
                        Log.e(TAG, it )
                    }
                }
                launch {
                    DataStore.userPhone.collect {
                       // it emits string value
                        Log.e(TAG, it )
                    }
                }
                launch {
                    DataStore.userAddress.collect {
                       // it emits string value
                        Log.e(TAG, it )
                    }
                }
            }

有没有更好的方法来收集碎片中的流量？就像在单个 launch{} 块中收集所有数据一样。

Answer 1

一种选择是将所有流程组合起来，如下所示：

combine(DataStore.userName, DataStore.userPhone, DataStore.userAddress) { userName, userPhone, userAddress ->
    // Operate on these values
}

另一种选择是使用launchIn它在提供的协程范围内启动流的集合。

viewLifecycleOwner.lifecycleScope.launchWhenStarted { 
    DataStore.userName.onEach { userName ->
        // ...
    }.launchIn(this)

    DataStore.userPhone.onEach { userPhone ->
        // ...
    }.launchIn(this)

    DataStore.userAddress.onEach { userAddress ->
        // ...
    }.launchIn(this)
}

launchIn只是 的简写scope.launch { flow.collect() }。