cartographie plat propriétés observables d'une collection observable dans RxSwift

Question

Utilisation RxSwift, que j'ai une classe A qui contient une observable de nombre entier

class A: { 
    let count: Observable<Int> 
} 

et une collection observable d'objets d'un

let data: Observable<[A]> 

Je veux définir un sum: Observable<Int> qui sera la somme de tous les count sur tous les objets dans data. Chaque fois que les modifications observables data ou l'une des modifications de la propriété count, le sum doit également changer.

Comment y parvenir? J'ai essayé quelques combinaisons flapMap et map mais seulement obtenu une solution quand sum obtient mis à jour seulement quand data obtient mis à jour, en ignorant les changements count.

Answer 1

let sum = data.flatMap { Observable.from($0).flatMap { $0.count }.reduce(0, accumulator: +) } 

'.reduce() émet seulement à la fin, de sorte qu'il doit être à l'intérieur de l'extérieur '.flatMap()'

Update 1:

 let sumSubject: BehaviorSubject<Observable<Int>> = BehaviorSubject.create(Observable.empty()) 
     let sum = sumSubject.switchLatest() 
     // every time it has to be a new 'data' observable! 
     sumSubject.onNext(data.flatMap { Observable.from($0).flatMap { $0.count }.reduce(0, accumulator: +) }) 

Mise à jour 2:

let counts: Observable<[Int]> = data.flatMap { Observable.combineLatest($0.map { $0.count }) } 
    let sum: Observable<Int> = counts.map { $0.reduce(0) { $0 + $1 } }