arrays - 使用 ReactiveCocoa 将元素的信号转换为具有大小的数组

Question

我试图找到一种方法将发送 X 元素的信号转换为受大小限制的 X 元素数组。

就像是：

signal.take(2).collect().observeNext{myFunction 中的变化(changes) }

但是完成后就死了。我需要它是：

• 取2个元素
• 将数组发送到函数
• 重复

任何想法？

Answer 1

我解决了这个任务（位置），这是我的解决方案

extention SignalProducer {
    func accumulate(size: Int) -> SignalProducer<[Value], Error> {
        var values: [Value] = []
        func next(value: Value) {
            if values.count >= size {
                values.removeAll()
            }
            values.append(value)
        }
        return on(next: next)
            .filter { _ in values.count < size }
            .map { _ -> [Value] in return values }
    }
}

https://github.com/ReactiveCocoa/ReactiveCocoa/pull/2817