[RxSwift] Transforming Operator (map, flatMap, scan, reduce)

오늘은 observable 데이터를 가공하는 operator에 대해 살펴보겠습니다.

1) Map

Observerble에 의해 방출되는 아이템들에 대해 각각 함수를 적용하여 변환합니다.

 

map을 사용하는 예시입니다.

let ob = Observable.of("1", "2", "3", "4")
ob.map { Int($0)! }
    .subscribe(onNext: { item in
        print(item)
    }).disposed(by: disposeBag)

//출력
//1
//2
//3
//4

string타입의 observable을 map operator를 통해 모든 item을 Int 타입으로 캐스팅 해주었습니다.

 

 

2) FlatMap

flatMap은 map과는 다르게 스트림에서 방출되는 아이템들을 다른 observable로 만듭니다. 

그러므로 flatMap의 리턴값은 생성된 observable입니다.

예시를 보겠습니다.

 

button.rx.tap
.flatMap { void -> Observable<[String]> in
    return fetchAllAnswers()
}.subscribe(onNext: { str in
    item.value = str
}).disposed(by: disposeBag)

func fetchAllAnswers() -> Observable<[String]> {
  let api = Observable.create { (obsever: AnyObserver<[String]>) -> Disposable in
       let answers = API.allAnswers()
        obsever.onNext(answers)
        obsever.onCompleted()
      return Disposables.create()
    }
    return api
}

버튼을 클릭했을 때, 데이터를 불러오는 fetchAllAnswers() 함수를 실행해 값을 발생하는 코드입니다.

 

3) Scan

이전에 방출된 아이템과 새로 방출된 아이템을 결합해 현재 아이템을 생성합니다.

 

예시 코드입니다.

Observable.of(1,2,3,4,5)
   .scan(0) { (prevValue, newValue) in
      return prevValue + newValue
   }
   .subscribe(onNext: { print($0) })
   .disposed(by: disposeBag)
// 출력
// 1
// 3
// 6
// 10
// 15

 

scan의 활용

 

1. 버튼 상태 변경

myButton.rx.tap
   .scan(false) { (lastState, newValue) in
      !lastState
   }
   .bind(to: requestMoreButton.rx.isSelected)
   .disposed(by: disposeBag)

 

2. 타이머 값 1 증가

myButton.rx.tap
   .scan(0) { (lastCount, newValue) in
      lastCount + 1
   }
   .subscribe(onNext: { print(“taps: \($0)”) })
   .disposed(by: disposeBag)

참고 : https://jusung.github.io/scan/

 

4) reduce

scan과 달리 마지막에 다 더한 값을 한번만 방출합니다.

 

예시 

Observable.of(1,2,3,4,5).reduce(0,accumulator: +)
    .subscribe(onNext: {
        print($0)
    }).disposed(by: disposeBag)