Swift Combine：在未调用序列发布者之后收集

Question

我有一个发送/接收数据数组的主题，例如PassthroughSubject<[Int], Never>()。当收到一个值时，我想将数组拆分为单个值来操作它们，然后再次收集它们。

我知道问题在于flatMap 永远不会发送完成事件。但是我该如何解决这个问题？或者有没有更好的方法来使用 combine 操作数组中的每个值？

编辑： 我不想完成要收集的主题。我想收集音序器的输出。

例子：

import Combine

var storage = Set<AnyCancellable>()
let subject = PassthroughSubject<[Int], Never>()

subject
    .flatMap { $0.publisher }
    .map { $0 * 10 }
    .collect()
    .sink {
        print($0) // Never called
    }
    .store(in: &storage)

subject.send([1, 2, 3, 4, 5])

Answer 1

我找到了实现预期结果的解决方案。我不得不在flatMap 中移动map 和collect。

import Combine

var storage = Set<AnyCancellable>()
let subject = PassthroughSubject<[Int], Never>()

subject
    .flatMap { $0.publisher
        .map { $0 * 10 }
        .collect()
    }
    .sink {
        print($0)
    }
    .store(in: &storage)

subject.send([1, 2, 3, 4, 5])
subject.send([1, 2, 3, 4, 5].reversed())

这将打印[10, 20, 30, 40, 50] 和[50, 40, 30, 20, 10]。

Answer 2

您不需要flatMap() 和collect() 调用，您可以简单地通过接收到的数组map()：

subject
    .map { $0.map { $0 * 10 } }
    .sink {
        print($0) // Now it's called :)
    }
    .store(in: &storage)

subject.send([1, 2, 3, 4, 5])

Answer 3

collect 等待发布者完成。 PassthroughSubject 不会自动完成。你需要拨打send(completion:就可以了。

subject.send([1, 2, 3, 4, 5])
subject.send(completion: .finished) // now `sink` will be triggered