[RxSwift] Zip
역할
두 개 이상의 Observable에서 방출된 순서가 같은 아이템을 묶어서 하나의 아이템으로 방출합니다.
예제
[코드]
let disposeBag = DisposeBag()
let numSubject = PublishSubject<Int>()
let charSubject = PublishSubject<String>()
let zippedObservable = Observable.zip(numSubject, charSubject)
zippedObservable
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
numSubject.onNext(1)
charSubject.onNext("A")
numSubject.onNext(2)
charSubject.onNext("B")
charSubject.onNext("C")
charSubject.onNext("D")
numSubject.onNext(3)
numSubject.onNext(4)
numSubject.onNext(5)
[실행 결과]
(1, "A")
(2, "B")
(3, "C")
(4, "D")
numSubject의 아이템 5에 대해서는 charSubject에서 같은 순서에 방출된 아이템이 없으므로 zip 결과로 아무런 아이템도 방출되지 않습니다.
활용
같은 순서쌍으로 처리해야하는 작업에 사용하면 편리 합니다.
예를들면, UITableView에서 선택한 Cell의 indexPath와 그 indexPath에 해당하는 model을 보장하는 처리를 하고 싶을때 zip을 사용할 수 있습니다.
첫번째 Observable: UITableView에서 선택된 아이템의 indexPath
두번째 Observable: UITableView에서 선택된 아이템의 model
[코드]
Observable.zip(tableView.rx.itemSelected, tableView.rx.modelSelected(ServiceType.self))
.subscribe(onNext: { [weak self] (indexPath, serviceType) in
self?.tableView.deselectRow(at: indexPath, animated: false)
self?.selectedServiceType.accept(serviceType)
})
.disposed(by: disposeBag)
indexPath을 이용해 선택된 Cell을 deselect하고, model은 선택된 Cell의 모델을 관리하기 위해 사용합니다.
[참 고]
