RxSwift - Sequence 내부의 요소들간의 결합 연산자(reduce, scan)

reduce 

 

제공된 초기값(0)에서 시작해서, source observable 이 방출할 때마다 값을 가공한다.

Observable.from((1...10))
//    .reduce(0, accumulator: { summary, newValue in
//        return summary + newValue
//    })
    .reduce(0, accumulator: +)
    .subscribe(onNext: {
        print($0)
    })
    .disposed(by: disposeBag)
    

----------reduce----------
55

 

scan

 

매번 값이 들어올 때마다 변형된 값들을 방출한다. 

print("----------scan----------")
Observable.from((1...10))
    .scan(0, accumulator: +)
    .subscribe(onNext: {
        print($0)
    })
    .disposed(by: disposeBag)
    

----------scan----------
1
3
6
10
15
21
28
36
45
55