[RxSwift] Combine Operator(CombineLatest, Merge, StartWith, Concat, Zip, WithLastFrom, Sample, SwitchLatest, Debounce)

rxSwift에 대한 강의를 듣다가 자주 사용하는 operator에 대해 정리해 놓으면 좋을 것 같다는 생각이 들더라구요

그래서 오늘은 유용하게 사용되는 operator들에 대해 정리해보도록 하겠습니다

계속 operator에 관해 사용할때마다 여기에 정리해 놓을려구요 !

 

Combine

서로 다른 스트림을 하나의 스트림으로 합칠때 사용하는 operator

 

CombineLatest

 

 

두 observable에서 아이템을 방출할때 가장 최신의 아이템을 결합하고, 결합된 아이템을 발행

let left = PublishSubject()  
let right = PublishSubject()

let observable = Observable.combineLatest(left, right, resultSelector: { lastLeft, lastRight in  
"(lastLeft) (lastRight)"  
})

let disposable = observable.subscribe(onNext: { value in  
print(value)  
})

left.onNext(5)  
left.onNext(3)  
right.onNext(2)  
right.onNext(1)  
left.onNext(99)

출력 결과 

3 2

3 1

99 1

두 observable이 각각 최초 발행되었을때 묶어 방출한다.

출처 : https://min-i0212.tistory.com/16

---

Merge

 

말그대로 병합입니다. 두개 이상의 Observable 출력을 결합하여 단일 Observable처럼 작동하게 함

merge하고 있는 여러 observable들을 동시에 subscribe하면서 먼저 오는 이벤트들을 바로 전달해준다.

let left = PublishSubject<String>()
let right = PublishSubject<String>()

let source = Observable.of(left.asObservable(), right.asObservable())

let observable = source.merge()

let disposable = observable.subscribe(onNext: { value in
    print(value)
})

var leftValues = ["Berlin", "Munich", "Frankfurt"]
var rightValues = ["Madrid", "Barcelona", "Valencia"]

repeat {
    if arc4random_uniform(2) == 0 {
        if !leftValues.isEmpty {
            left.onNext("Left:  " + leftValues.removeFirst())
        }
    } else if !rightValues.isEmpty {
        right.onNext("Right: " + rightValues.removeFirst())
    }
} while !leftValues.isEmpty || !rightValues.isEmpty

disposable.dispose()

출력 결과 (항상 다르게 나온다)

Left: Berlin 

Left: Munich 

Right: Madrid 

Right: Barcelona 

Right: Valencia 

Left: Frankfurt

 

출처: https://rhammer.tistory.com/309 

 

---

StartWith

Observable 시작하기 전에 지정된 항목 시퀀스를 방출

let number = Observable.of(2,3,4)
    number.startWith(1)
    .subscribe(onNext: {
        print($0)
    }).disposed(by: disposeBag)

---

Concat

2개 이상의 observable을 순서대로 묶음

let start = Observable.of(1,2,3,4)
let end = Observable.of(5, 6, 7, 8)
let observable = Observable.concat(start, end)
observable.subscribe(onNext: {
    print($0)
}).disposed(by: disposeBag)

---

Zip

두 개 이상의 Observable에서 발행 순서가 같은 아이템을 묶어 발행

enum Weather { case cloudy, sunny }

let left: Observable < Weather > = Observable.of(.sunny, .cloudy, .cloudy, .sunny) 
let right = Observable.of("Lisbon", "Copenhagen", "London", "Madrid", "Vienna")

let observable = Observable
.zip(left, right, resultSelector: { (weather, city) in 
return "It's \(weather) in \(city)."
})

observable.subscribe(onNext: { print($0) }).disposed(by: disposeBag)

출력 결과

It's sunny in Lisbon. 

It's cloudy in Copenhagen. 

It's cloudy in London. 

It's sunny in Madrid.

 

출처 : https://rhammer.tistory.com/311?category=649741

 

---

WithLastFrom

두 observable 중 첫번째 observable에서 아이템이 방출될때마다 그 아이템을 두번째 observable의 가장 최근 아이템과 결합해 방출 

let disposeBag = DisposeBag()
    
let numSubject  = PublishSubject<Int>()
let charSubject = PublishSubject<String>()
    
numSubject
    .withLatestFrom(charSubject) { "\($0)\($1)"}
    .subscribe(onNext: { print($0) })
    .disposed(by:disposeBag)
    
numSubject.onNext(1)     // 아이템 방출되지 않음 : charSubject에서 방출된 아이템이 아직 1개도 없으므로
    
charSubject.onNext("A")
    
numSubject.onNext(2)     // 2A
    
charSubject.onNext("B")
    
charSubject.onNext("C")
charSubject.onNext("D")
    
numSubject.onNext(3)     // 3D charSubject에서 가장 최근 아이템 D와 결합
numSubject.onNext(4)     // 4D
numSubject.onNext(5)     // 5D

출력 결과

2A

3D

4D

5D

특정 값을 특정 이벤트를 통해 최신 값을 받아오는데 사용 할 수 있다.

출처 : https://jusung.github.io/withLatestFrom/

---

Sample

두 observable 중 두번째 observable에서 아이템이 방출될때마다 첫번째 observable내 가장 최신 값을 방출한다. 방출된 값이 있다면 같은 값을 방출하지 않는다.

withLatestFrom(_:) 와 distinctUntilChanged()을 합쳐 놓은 것

 

---

SwitchLatest

두 개 이상의 Observable에서 결합하되 가장 최신의 아이템으로 발행됩니다.

// 1
let one = PublishSubject<String>() 
let two = PublishSubject<String>() 
let three = PublishSubject<String>() 
let source = PublishSubject<Observable<String>>()



// 2 
let observable = source.switchLatest() 
let disposable = observable.subscribe(onNext: { value in 
	print(value) 
}).disposed(by: disposedBag)

// 3 
source.onNext(one) 
one.onNext("Some text from sequence one") 
two.onNext("Some text from sequence two") 

source.onNext(two) 
two.onNext("More text from sequence two") 
one.onNext("and also from sequence one") 

source.onNext(three) 
two.onNext("Why don't you see me?") 
one.onNext("I'm alone, help me") 
three.onNext("Hey it's three. I win.") 

source.onNext(one) 
one.onNext("Nope. It's me, one!")

disposable.dispose()

출력 결과

Some text from sequence one

one More text from sequence two 

Hey it's three. I win. 

Nope. It's me, one!

 

출처: https://rhammer.tistory.com/350?category=649741 

 

---

Debounce

타이머를 지정해두고 타이머가 끝난 시점에서 가장 최신의 값을 반환해줍니다.