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

Question

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

类似于：

signal.take（2）.collect（）.oobserveNext｛中的更改myFunction（更改）}

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

• 取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