RxSwift - Combining Operator

contents

🟣 Combining Operator

🟣 Combining Operator의 종류

Combining Operator

Combining Operator는 Sequence들을 모으고, 각 Sequence 내의 데이터를 병합하는 Operator입니다.

즉, 서로 다른 스트림을 하나의 스트림으로 합쳐서 사용해야 하거나, 여러 Observable을 묶어서 사용해야 할 때 해당 연산자를 사용하면 됩니다.

URL Request에서 두 개의 응답을 받아서 하나로 묶어서 처리해야 한다거나, 아이디와 비밀번호 입력을 받고, 각각의 이벤트들을 섞어서 유효성 검사를 해야 한다면 Combining Operator를 사용하면 편합니다.

Combining Operator의 종류

startWith

Observable이 아이템을 발행하기 전에 특정 아이템을 먼저 발행

startWith는 Observable 시퀀스 앞에 다른 값 하나를 추가시켜줍니다. 처음 이벤트 값을 넣어주고 싶다면 startWith를 사용하면 됩니다.

let disposeBag = DisposeBag()
let observable = Observable.of("효연", "유리", "수영", "윤아", "서현")

observable
    .startWith("태연")
    .startWith("써니")
    .startWith("티파니")
    .subscribe(onNext: {
        print($0)
    })
    .disposed(by: disposeBag)

/*
티파니
써니
태연
효연
유리
수영
윤아
서현
*/
Swift
복사

combineLatest

두 Observable에서 각각의 이벤트가 발생할 때, 그 이벤트들 중에 마지막 이벤트들을 묶어서 전달

combineLatest는 여러 Observable에서 가장 최신 값을 병합하여 방출합니다. 여러 Observable 중 하나의 Observable만 값을 방출한다면 아무일도 일어나지 않습니다.

하지만, 모든 Observable이 값을 한 번씩 방출했다면 그 이후에는 방출하는 최신값을 받습니다.

let disposeBag = DisposeBag()
let person = PublishSubject<String>()
let dog = PublishSubject<String>()

Observable
    .combineLatest(person, dog, resultSelector: { lastPerson, lastDog in
        "\(lastPerson)네 강아지 \(lastDog)"
    })
    .subscribe(onNext: {
        print($0)
    })
		.disposed(by: disposeBag)

person.onNext("철수")
person.onNext("짱구")
dog.onNext("콩이")
dog.onNext("흰둥이")
person.onNext("훈이")

// person ---철수---짱구------------훈이-----
//    dog -------------콩이---흰둥이---------
/*
짱구네 강아지 콩이
짱구네 강아지 흰둥이
훈이네 강아지 흰둥이
*/
Swift
복사

withLatestFrom

한쪽 Observable의 이벤트가 발생할 때, 두 개의 Observable을 병합

withLatestFrom는 특정 트리거 발생 시, 특정 상태의 최신 값을 얻고 싶을 때 사용합니다. 병합할 다른 Observable에 이벤트가 없다면 이벤트는 스킵됩니다.

let disposeBag = DisposeBag()
let button = PublishSubject<Void>()
let textField = PublishSubject<String>()

button
    .withLatestFrom(textField)
    .subscribe(onNext: {
        print($0)
    })
		.disposed(by: disposeBag)

textField.onNext("ㄱ")
textField.onNext("거")
textField.onNext("검")
textField.onNext("검색")
textField.onNext("검색!")
button.onNext(())
button.onNext(())

/*
검색!
검색!
*/
Swift
복사

withLatestFrom와 distinctUntilChanged를 합친 sample Operator를 사용하게 되면 위에서 발생하는 중복 문제도 막을 수 있습니다.

let disposeBag = DisposeBag()
let button = PublishSubject<Void>()
let textField = PublishSubject<String>()

textField
    .sample(button)
    .subscribe(onNext: {
        print($0)
    })
    .disposed(by: disposeBag)

textField.onNext("ㄱ")
textField.onNext("거")
textField.onNext("검")
textField.onNext("검색")
textField.onNext("검색!")
button.onNext(())
button.onNext(())

/*
검색!
*/
Swift
복사

merge

여러 Observable을 하나로 합쳐서 아이템을 발행

merge는 시퀀스를 합쳐주는 Operator입니다. merge하고 있는 여러 시퀀스들을 동시에 구독하면서 먼저 오는 이벤트를 바로 바로 방출합니다.

내부 시퀀스가 completed되는 시점은 모두 독립적이지만, 내부 시퀀스가 종료되면 merge 시퀀스도 종료됩니다. 만약, 내부 시퀀스가 error 이벤트를 방출하면 merge 시퀀스도 에러를 방출시키면서 종료됩니다.

merge는 여러 Observable을 하나로 합쳐야 하기 때문에 이벤트 타입이 같아야지만 가능합니다.

let disposeBag = DisposeBag()
let a = Observable.of(10, 4, 3, 2)
let b = Observable.of(4, 5, 2, 1)

Observable.merge(a, b)
    .subscribe(onNext: {
        print($0, terminator: " ")
    })
    .disposed(by: disposeBag)

/*
10 4 4 5 3 2 2 1
*/
Swift
복사

zip

두 Observable의 발생 순서가 같은 이벤트를 조합해서 방출

zip은 combineLatest와 비슷하지만 다른 개념입니다. combineLatest는 각 스트림에서 이벤트가 발생하면 바로 새로운 이벤트가 내려오지만, zip은 모든 스트림에 같은 횟수의 이벤트가 들어올 때 이벤트를 방출시킵니다. 이벤트가 쌍을 이루지 않는다면 이벤트를 방출시키지 않습니다.

let disposeBag = DisposeBag()
let flower = Observable.of("james", "nick", "thomas", "john")
let basket = Observable.of("charlotte", "vicky", "ellen")

Observable.zip(flower, basket)
    .subscribe(onNext: {
        print($0) })
    .disposed(by: disposeBag)

/*
("james", "charlotte")
("nick", "vicky")
("thomas", "ellen")
*/
Swift
복사

switchLatest

Observable에서 발행하는 Observable을 다른 Observable로 변경하여 아이템 발행

가장 최신의 Observable에서 발행하는 이벤트를 발행합니다. Observable를 선택적으로 처리하고 싶을 때 사용하면 됩니다.

let disposeBag = DisposeBag()
let netfilx = PublishSubject<String>()
let tving = PublishSubject<String>()
let remoteControl = BehaviorSubject<Observable<String>>(value: netfilx)

remoteControl
    .switchLatest()
    .subscribe {
        print($0)
    }
    .disposed(by: disposeBag)

netfilx.on(.next("D.P."))
remoteControl.on(.next(tving))
netfilx.on(.next("마스크걸"))
tving.on(.next("유미의세포들"))
tving.on(.next("술꾼도시여자들"))

/*
next(D.P.)
next(유미의세포들)
next(술꾼도시여자들)
*/
Swift
복사

concat

여러 Sequence를 순서대로 묶어줌

첫 번째 Sequence가 완료될 때까지 구독하고 다음 Sequence를 같은 방법으로 구독합니다.

concat은 요소들이 같은 타입일 때 사용 가능하고, 여러 개의 요소를 앞 뒤로 추가 가능합니다.

let disposeBag = DisposeBag()
let carnivore = Observable.of("호랑이", "사자")
let omnivore = Observable.of("강아지", "여우")
let herbivores = Observable.of("코끼리", "사슴")

Observable
    .concat([carnivore, omnivore, herbivores])
    .subscribe(onNext: {
        print($0)
    })
    .disposed(by: disposeBag)

/*
호랑이
사자
강아지
여우
코끼리
사슴
*/
Swift
복사

reduce

모든 값을 더한 값 방출

Swift에서 제공해주는 reduce 메서드로도 동일하게 모든 값을 더할 수 있습니다.

let disposeBag = DisposeBag()
let receipt = Observable.of(10000, 23000, 150000, 40000)

receipt
    .reduce(0, accumulator: +)
    .subscribe(onNext: {
        print($0)
    })
    .disposed(by: disposeBag)

/*
223000
*/
Swift
복사

scan

하나씩 더할 때마다 증가된 값을 방출

scan은 값을 저장할 수 있고, 그 값을 통해 이벤트를 변형할 수 있습니다. 변형하는 이벤트의 타입은 원본 이벤트의 타입과 같아야 합니다.

scan은 증가된 값들의 기본이 될 초기값을 지정해야 합니다.

let disposeBag = DisposeBag()
let observable = Observable.of("1,", "2,", "3,", "4,", "5")

observable
    .scan("number: ") { $0 + $1 }
    .subscribe(onNext: {
        print("\($0)")
    })
    .disposed(by: disposeBag)

/*
number: 1,
number: 1,2,
number: 1,2,3,
number: 1,2,3,4,
number: 1,2,3,4,5
*/
Swift
복사