Swift 合并接收器数组 AnyPublisher

Question

我想等待所有元素的数据并将它们组合成一个结果：

Item: AnyPublisher <Int, Swift.Error>
Array: AnyPublisher <[Result<Int, Swift.Error>], Never>

这可以以某种方式完成吗？我尝试过使用 Zip 和 Merge - 但我无法获得想要的结果。

例子：

func createItem(num: Int) -> AnyPublisher<Int, Swift.Error> {
    Just(num)
        .setFailureType(to: Swift.Error.self)
        .eraseToAnyPublisher()
}
func createItems(nums: [Int]) -> AnyPublisher<[Result<Int, Swift.Error>], Never> {
    Publishers.MergeMany(nums.map { self.createItem(num: $0) } )
        .collect()
        .eraseToAnyPublisher()
}

功能但“createItems”不起作用

Answer 1

您似乎想要生成一个结果数组 - 无论是值还是错误 - 由每个发布者为每个数组值发出。

MergeMany + Collect 是正确的方法。 MergeMany 将仅在其所有输入发布者完成时完成，.collect() 将在发出之前完成该完成事件。

使用您的示例：

func createItems(nums: [Int]) -> AnyPublisher<[Result<Int, Error>], Never> {

    let publishers = nums.map { v -> AnyPublisher<Result<Int, Error>, Never> in
        createItem(num: v) // AnyPublisher<Int, Error>
           .first() // ensure a single result
           .map { .success($0) } // map value to .success result
           .catch { Just(.failure($0)) } // map error to .failure result
           .eraseToAnyPublisher()
    }

    return Publishers.MergeMany(publishers)
        .collect() // wait for MergeMany to complete
        .eraseToAnyPublisher()
}