combine operator 의 한 종류이다.

복수개의 스트림을 하나의 스트림으로 만들어준다.

연관 글: zip

사용 예시

• [ ] 다양한 예시 코드 찾고 읽어보기

• validation 을 통한 버튼 활성화

  • 예시) 1번 , 2번 항목을 조건에 맞게 입력해야 버튼이 활성화된다.
  • [x] 간단한 예제 구현해보기

  // isIDValid: Observable<Bool>
  // isPasswordValid: Observable<Bool>
  
  Observable.combineLatest(isIDValid, isPasswordValid)
  	.filter { $0.0 && $0.1 }
  	.map {
  		// 버튼 활성화 로직
  	}.disposed(by: disposeBag)
  

• 예시 링크

  • combineLatest 와 zip 을 비교하여 설명해주는 글

    func exampleCombineLatest(a: Observable<Int>) -> Observable<(Int, String)> {
        let b = a.map { "\\($0)" }
        return Observable.combineLatest(a, b)
    }
    
    exampleCombineLatest(a: Observable.from([1, 2, 3]))
        .subscribe(onNext: { print("combineLatest", $0) })
    
    //prints
    combineLatest (1, "1")
    combineLatest (2, "1")
    combineLatest (2, "2")
    combineLatest (3, "2")
    combineLatest (3, "3")
    

개요

• 원본 옵저버블이 방출하는 최신 요소를 병합한 이벤트를 방출하는 옵저버블을 반환한다.

Description

• combine 되는 스트림들의 element 타입은 모두 달라도 된다.
• 3개의 스트림을 하나의 스트림으로 만들어주는 예시

static func combineLatest<O1, O2, O3>(_ source1: O1, _ source2: O2, _ source3: O3) -> Observable<(O1.Element, O2.Element, O3.Element)> where O1 : ObservableType, O2 : ObservableType, O3 : ObservableType

2개의 스트림을 하나의 스트림으로 만들어주는 예시

특징

• 최대 8 개의 옵저버블을 받는 연산자가 오버로딩 되어있다.
• 어느쪽에서 이벤트가 방출되면 combine 대상의 옵저버블들의 최신 이벤트들만 가져오는 이벤트가 발생된다.
  • 즉, 원본 옵저버블에서 최초 1회씩 방출이 되어야 병합된 옵저버블 스트림이 시작된다.
• 최초 기본 값을 주고 싶다면?
  • startWith 혹은
  • BehaviorSubject 를 사용한다
• combine 된 옵저버블 중 하나가 completed 이벤트를 방출했다면, 이후 부터는 그 옵저버블에서가장 나중에 사용한 next 이벤트를 방출한다