如何在Kotlin中将Flow<T>转换为StateFlow<List<T>>？

问题场景 #

现有如下Flow：

val flow = flow {
    for (i in 1..100) {
      emit(i)
    }
  }

需要将这个Flow<Int>转换为StateFlow<List<Int>>，从而通过StateFlow<T>.collectAsStateWithLifecycle在界面展示所有元素，且不能修改原flow内部的代码（比如不能改成emit列表的形式）。

实现方案 #

可以借助Flow的scan操作符累积元素，再通过stateIn转换为StateFlow，具体代码如下：

val stateFlow = flow
    // 累积每个发射的元素，生成包含所有历史元素的列表
    .scan(emptyList<Int>()) { accumulatedList, newItem ->
        accumulatedList + newItem
    }
    // 将Flow转换为StateFlow
    .stateIn(
        scope = viewModelScope, // 替换为你实际使用的CoroutineScope（如ViewModel的viewModelScope）
        started = SharingStarted.WhileSubscribed(5000), // 适合界面场景的订阅策略，无订阅者后延迟5秒停止
        initialValue = emptyList() // StateFlow的初始值
    )

关键操作符说明 #

• scan：以空列表为初始值，每次接收新元素时将其追加到累积列表中，返回持续发射完整累积列表的Flow。
• stateIn：将普通Flow转换为StateFlow，需要指定CoroutineScope、订阅启动策略和初始值，确保StateFlow能配合界面生命周期安全工作。

界面使用示例 #

在界面中通过collectAsStateWithLifecycle收集StateFlow，即可拿到所有元素的列表用于渲染：

val items by stateFlow.collectAsStateWithLifecycle()
// 示例：用LazyColumn展示所有元素
LazyColumn {
    items(items) { item ->
        Text(text = item.toString())
    }
}

内容的提问来源于stack exchange，提问作者SageJustus