你正在做的不正确的事情并没有害处，但只是让你的代码变得不必要的复杂：

• 在getProducts函数中，您不需要将流 Package 在emitAll的flow构建器中。删除外部flow { } Package 器和.also { emitAll(it) }。
• 永远不要使用async { }.await()模式。这和直接调用lambda中的代码没有什么不同。当编译器检测到你这样做时，它应该会发出警告。
• onEach { }.collect()模式可以缩短为.collect { }，或者按照我的喜好，collect()可以变为launchIn(scope)并替换外部的scope.launch以减少代码嵌套/缩进。
• 在collectProducts()中，您使用coroutineScope创建了一个作用域，但从未使用它来运行任何子协程，因此这是毫无意义的。
• 如果你使用的Flows来自于知名的库，如Retrofit、Room或Firebase，你不需要使用flowOn，因为它们正确地封装了任何阻塞工作。公共流不应该阻塞它们的下游收集器。同样，你不应该需要withContext来调用这些库中的suspend函数，因为按照惯例，suspend函数应该永远不会阻塞。

你正在做的不正确和有害的事情：

• 在loadCategoriesAndProducts()中，您将SharedFlow传递给另一个收集它的函数。这是创建两个流的乘法，随着项目的到达，它将呈指数级增长。这可以更简单地解决，如下所示。您需要做的只是将两个流合并。
• 您应该使用repeatOnLifecycle或flowWithLifecycle，以避免在Activity处于屏幕外时收集，因为这会浪费资源。
• 在你的categories?.forEach {块中，你正在做不必要的嵌套迭代。

如果你想使用SharedFlow，这可以避免导致新的请求必须重新生成，那么你应该在你的ViewModel中放置一个函数，将networkID馈送到一个MutableShateFlow中，作为另一个SharedFlow的基础。你可以在这里私下声明你的两个并行流，然后公开合并它们。

// In ViewModel class:
private val _networkId = MutableStateFlow<String?>(null)
var networkId: String?
    get() = _networkId.value
    set(value) { _networkId.value = value }

private val products = _networkId.filterNotNull().distinctUntilChanged()
    .flatMapLatest { networkId ->
        request.getAll("network/${networkId}/products", null)
            .onStart { emit(ApiResult.Loading) }
            .catch { emit(ApiResult.Error(it.message.toString())) }
            .map { ApiResult.Success(it) }
    }

private val categories = _productsNetworkId.filterNotNull().distinctUntilChanged()
    .flatMapLatest { networkId ->
        request.getAll("network/${networkId}/categories", null) // I'm just guessing
            .onStart { emit(ApiResult.Loading) }
            .catch { emit(ApiResult.Error(it.message.toString())) }
            .map { ApiResult.Success(it) }
    }

val categoriesAndProducts: SharedFlow<ApiResult<List<Any>>> =
    products.combine(categories) { p, c ->
        when {
            p is ApiResult.Loading, c is ApiResult.Loading -> ApiResult.Loading
            p is ApiResult.Error -> p
            c is ApiResult.Error -> c
            else -> { // both are Success
                ApiResult.Success( 
                    c.data.orEmpty().flatMap { category ->
                        listOf(category) + p.data.orEmpty().filter { it.categoryId = category.id }
                    }
                )
            }
        }
    }.shareIn(viewModelScope, SharingStarted.WhileSubscribed(5000L), replay = 1)

然后在您的活动中：

private fun loadCategoriesAndProducts() {
    viewModel.networkId = networkId
    viewModel.categoriesAndProducts
        .onEach { 
            when(it) {
                is ApiResult.Loading -> {} // Handle loading
                is ApiResult.Error -> {} // Handle error

                is ApiResult.Success -> {
                    productsAdapter.updateData(productCategoryList) {
                        loadingIndicator.visibility = View.INVISIBLE
                    }
                }
            }
        }
        .flowWithLifecycle(this, Lifecycle.State.STARTED)
        .launchIn(lifecycleScope)
}

除此之外，MutableList<Any>的使用是一种代码气味，会产生代码可维护性问题。