[RxSwift] Combining Observables 알아보기 (Combine Latest,Zip, Merge,Concat,withLatestFrom)

안녕하세요 Foma 입니다!

 

오랜만에 RxSwift 글을 포스팅을 하는데.. 써야지 써야지 미루다가 쓰게 됩니다...

 

오늘은 여러개의 이벤트들을 합쳐주는 연산자들을 알아보도록 하겠습니다!

바로 시작할게요~

---

1.CombineLatest

 

여러개의 옵저버블의 가장 마지막의 값을 합쳐서 하나의 결과로 방출합니다.

 

다음과 같이 각각 색깔,모양,숫자를 방출하는 서브젝트가 있습니다.

let 색깔 = PublishSubject<String>()
let 모양 = PublishSubject<String>()
let 숫자 = PublishSubject<Int>()

컴바인레이티스트로 각 옵저버블을 묶은 뒤 구독을 하여 방출하는 값을 출력해봅니다.

let combineLatest = Observable.combineLatest(색깔,모양,숫자) {색깔,모양,숫자 in "\(색깔),\(모양),\(숫자)"}
combineLatest.subscribe({print($0)})

만약 이렇게 검정색인 색깔을 방출하면 어떤 값이 출력될까요?

 

정답은 아무것도 방출되지 않습니다.

 

3개의 옵저버블의 가장 마지막 값을 묶어서 만드는 값이므로 최소 각각의 옵저버블별로 하나의 데이터를 방출해야합니다.

색깔.onNext("검정색")

위의 색깔과 모양 숫자 이렇게 3개의 옵저버블이 각 데이터를 방출하면 검정색,동그라미,1이 하나로 합쳐져서 방출되게 됩니다.

모양.onNext("동그라미")
숫자.onNext(1)
//next(검정색,동그라미,1)

여기서 색깔이 파란색으로 방출되면 어떻게 될까요?

 

가장 마지막에 방출된 모양과 숫자가 합쳐져 파란색 동그라미 1로 방출되게 됩니다.

색깔.onNext("파란색")
//next(파란색,동그라미,1)

---

2.Zip

 

여러개의 옵저버블의 값을 합쳐서 하나의 결과로 방출합니다.

 

아까와 같이 색깔과 모양과 숫자가 있습니다.

let 색깔 = PublishSubject<String>()
let 모양 = PublishSubject<String>()
let 숫자 = PublishSubject<Int>()

let zip = Observable.zip(색깔,모양,숫자)  {색깔,모양,숫자 in "\(색깔),\(모양),\(숫자)"}
zip.subscribe({print($0)})

컴바인 레이티스트와 같이 각 옵저버블이 최소 하나라도 방출되야 출력이 됩니다.

 

아래와 같이 색깔만 방출댔을땐 아무것도 출력되지 않습니다.

색깔.onNext("검정색")

이렇게 모양과 숫자까지 방출해주면 검정색,동그라미,1이 방출되게 됩니다.

모양.onNext("동그라미")
숫자.onNext(1)
//next(검정색,동그라미,1)

그러면 CombineLatest와 다른 점은 무엇일까요?

 

색깔을 파란색으로 방출하게 되면 아무런 것도 출력되지 않습니다.

색깔.onNext("파란색")

 

즉, 새롭게 방출된 각 데이터들을 합쳐서 하나의 데이터로 방출하는 것입니다.

색깔.onNext("검정색")
모양.onNext("동그라미")
숫자.onNext(1)
색깔.onNext("파란색")
모양.onNext("네모")
숫자.onNext(2)
//next(검정색,동그라미,1)
//next(파란색,네모,2)

---

3.Merge

 

여러개의 옵저버블을 합쳐 각각 방출된 데이터를 모두 방출합니다.

 

위와 같이 색깔,모양,숫자가 있습니다.

 

하지만 다른 점은 숫자가 String이죠?

 

merge는 방출되는 데이터 형이 모두 똑같아야 합니다.

let 색깔 = PublishSubject<String>()
let 모양 = PublishSubject<String>()
let 숫자 = PublishSubject<String>()

구독한 뒤 데이터를 출력해보면 묶어준 옵저버블에서 방출된 데이터 모두를 방출합니다.

let merge = Observable.merge(색깔,모양,숫자)
merge.subscribe{print($0)}

색깔.onNext("검정색")
모양.onNext("동그라미")
숫자.onNext("1")
색깔.onNext("파란색")
//next(검정색)
//next(동그라미)
//next(1)
//next(파란색)

---

4.Concat

 

여러개의 옵저버블이 방출한 데이터를 차례로 방출합니다.

 

 

컨캣도 멀지와 마찬가지로 모든 형이 같아야 합니다.

 

색깔,모양,숫자를 차례로 묶었다면 색깔의 데이터가 모두 방출된 후 즉, 컴플릿이 방출된 이후에 방출된 모양의 데이터가 방출되고

 

모양의 데이터가 컴플릿이 되고 숫자의 데이터가 방출됩니다.

 

컴플릿이 되기 전에 방출된 그 전의 옵저버블 데이터는 방출되지 않습니다.

let 색깔 = PublishSubject<String>()
let 모양 = PublishSubject<String>()
let 숫자 = PublishSubject<String>()

let concat = Observable.concat(색깔,모양,숫자)
concat.subscribe{print($0)}

색깔.onNext("검정색")
색깔.onNext("파란색")
모양.onNext("네모")
색깔.onCompleted()
모양.onNext("동그라미")
모양.onCompleted()
숫자.onNext("1")
//next(검정색)
//next(파란색)
//next(동그라미)
//next(1)

---

5.withLatestFrom

 

가장 마지막에 방출한 데이터를 방출합니다.

 

아래와 같이 만약 버튼과 텍스트필드가 있고 버튼을 눌렀을때 텍스트필드의 값을 방출한다고 가정할때

 

우리는 텍스트필드의 맨 마지막 데이터를 원할 것입니다.

 

그럴때 알맞는 연산자라고 볼 수 있습니다.

let button = PublishSubject<Bool>()
let textField = PublishSubject<String>()

let withLatestFrom = button.withLatestFrom(textField)
withLatestFrom.subscribe({print($0)})

textField.onNext("S")
textField.onNext("Swi")
button.onNext(true)
textField.onNext("Swif")
textField.onNext("Swift")
button.onNext(true)
//next(Swi)
//next(Swift)

---

이렇게 오늘은 여러개의 옵저버블을 합쳐주는 오퍼레이터에 대해서 알아보았는데요.

 

혹시라도 틀린 점이 있거나 궁금하신 부분이 있다면 댓글로 알려주세요!