如何不使用LiveData观察WorkManager的Worker运行状态

核心问题说明 #

• asStateFlow() 调用失败的核心原因：该扩展方法要求目标LiveData存在活跃观察者，且依赖lifecycle-livedata-ktx:2.6.0+版本，直接在ViewModel中对无观察者的LiveData调用该方法必然触发异常，不需要强行做LiveData到Flow的转换，WorkManager 2.8.0+版本已经原生提供Flow形式的状态查询API。

实现步骤 #

1. 引入对应依赖 #

首先确保引入ktx版本的WorkManager依赖，原生支持Flow返回值：

// 模块级build.gradle 依赖配置
implementation "androidx.work:work-runtime-ktx:2.9.0"

2. ViewModel层直接获取Work状态流 #

替换原有getWorkInfoByIdLiveData调用，直接使用getWorkInfoByIdFlow获取状态流，可直接映射为UI层需要的状态，通过stateIn转为可观察的StateFlow：

// 先定义UI层直接使用的同步状态密封类
sealed class FtpSyncState {
    object Idle : FtpSyncState()
    object Loading : FtpSyncState()
    data class Success(val syncData: Data) : FtpSyncState()
    object Error : FtpSyncState()
}

class FtpSyncViewModel(private val workManager: WorkManager) : ViewModel() {
    fun observeSyncWork(workId: UUID): StateFlow<FtpSyncState> {
        return workManager.getWorkInfoByIdFlow(workId)
            .flowOn(Dispatchers.IO)
            .map { workInfo ->
                when (workInfo?.state) {
                    WorkInfo.State.ENQUEUED,
                    WorkInfo.State.RUNNING -> FtpSyncState.Loading
                    WorkInfo.State.SUCCEEDED -> FtpSyncState.Success(workInfo.outputData)
                    WorkInfo.State.FAILED,
                    WorkInfo.State.CANCELLED -> FtpSyncState.Error
                    else -> FtpSyncState.Idle
                }
            }
            .stateIn(
                scope = viewModelScope,
                started = SharingStarted.WhileSubscribed(5000),
                initialValue = FtpSyncState.Idle
            )
    }
}

3. Activity层生命周期安全收集流 #

不需要使用Observer，直接通过lifecycleScope配合repeatOnLifecycle收集状态流，自动在页面退到后台时停止收集，避免内存泄漏：

class FtpSyncActivity : AppCompatActivity() {
    private val viewModel: FtpSyncViewModel by viewModels()
    // 启动FTP同步Worker时保存的任务UUID
    private val syncWorkId: UUID = 你自己的任务ID

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_ftp_sync)

        lifecycleScope.launch {
            repeatOnLifecycle(Lifecycle.State.STARTED) {
                viewModel.observeSyncWork(syncWorkId).collect { state ->
                    // 根据状态直接更新UI
                    when (state) {
                        FtpSyncState.Idle -> showIdleHint()
                        FtpSyncState.Loading -> showLoadingView()
                        is FtpSyncState.Success -> renderSyncData(state.syncData)
                        FtpSyncState.Error -> showErrorToast()
                    }
                }
            }
        }
    }
}

如果你确实需要存量LiveData转Flow，不要直接调用asStateFlow()，先调用asFlow()将LiveData转为普通冷流，再通过stateIn()方法结合协程作用域转换为StateFlow即可。

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