您认为实现返回流的用例/存储库的正确方法是什么（单一事实来源 + 远程获取）

问：

假设我有以下用例将用户作为流获取

class FetchUsersFlowUseCase(
    private val userRepository: UserRepository
) {

    operator fun invoke(): Flow<List<User>> {
        return userRepository.fetchUsersFlow()
    }
}

以及一个具有将用户作为 Flow 获取函数的存储库。调用该函数时，还会尝试同步本地数据库（即单一事实来源）。

class UserRepositoryImpl(
    private val localUserDataSource: LocalUserDatasource,
    private val remoteUserDataSource: RemoteUserDatasource,
    private val coroutineScope: CoroutineScope
) : UserRepository {

    override fun fetchUsersFlow(): Flow<List<User>> {
        coroutineScope.launch {
            val remoteUsersResult = remoteUserDataSource.fetchUsers()
            if (remoteUsersResult.isSuccess) {
                // Success: update users locally
            } else {
                // What to do? 
                // How to correctly notify who observes that something wrong happened?
            }
        }

        return localUserDataSource.fetchUsersFlow()
    }
}

但是，如果发生意外情况（例如：没有 Internet 连接），我该如何正确通知谁观察了 Flow？