Transformieren von Signal von Elementen in Arrays mit Größe mit ReactiveCocoa

Question

Ich versuche, eine Möglichkeit zu finden, ein Signal zu transformieren, das X-Element in Arrays von X-Elementen begrenzt durch die Größe sendet.

Etwas wie:

signal.take (2) .collect() {observeNext Änderungen in myFunction (Änderungen) }

Aber das stirbt nach abgeschlossen.. Ich muss es sein:

• Take 2 Elemente
• senden Array
• Repeat

Jede Idee zu funktionieren?

Answer 1

Ich löste diese Aufgabe (für die Lage) und es ist meine Lösung

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