RxSwift - Transforming Operator

contents

🟣 Transforming Operator

toArray

Transforming Operator

Transforming Operator는 Observable이 내보내는 이벤트 타입을 변환하는 연산자입니다.

toArray

Observable이 방출하는 모든 요소를 배열에 담아 방출

toArray는 completed 이벤트 전까지 이벤트를 전달하기 않다가 completed 시에 이벤트를 방출합니다.

원래는 Observable를 리턴했는데, RxSwift 5.0부터 Single 타입을 리턴합니다.

let disposeBag = DisposeBag()
let subject = PublishSubject<Int>()

subject
    .toArray()
    .subscribe(onSuccess: {
        print($0)
    })
    .disposed(by: disposeBag)

subject.onNext(1)
subject.onNext(2)
subject.onCompleted()

/*
[1, 2]
*/
Swift
복사

map

Swift의 고차함수 map과 동일하게 각각의 값을 변경하고자 할 때 사용

map은 값을 변경하고자 사용하기 때문에 전달받은 요소의 타입과 리턴하는 요소의 타입이 같지 않아도 됩니다.

let disposeBag = DisposeBag()
let formatter = NumberFormatter()
formatter.numberStyle = .spellOut

Observable<NSNumber>.of(123, 4, 56)
    .map { formatter.string(from: $0) ?? "" }
    .subscribe(onNext: {
        print($0)
    })
    .disposed(by: disposeBag)

/*
백이십삼
사
오십육
*/
Swift
복사

flatMap

Observable의 이벤트를 받아서 새로운 Observable로 변환해서 방출

새로운 Observable은 새로운 타임라인을 가지게 됩니다. 각 Observable Sequence들은 하나의 Observable Sequence로 병합됩니다.

struct Student {
    var score: BehaviorSubject<Int>
}

let disposeBag = DisposeBag()
let ryan = Student(score: BehaviorSubject(value: 80))
let charlotte = Student(score: BehaviorSubject(value: 90))
let student = PublishSubject<Student>()

student
    .flatMap { $0.score }
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)

student.onNext(ryan)
ryan.score.onNext(85)
student.onNext(charlotte)
ryan.score.onNext(95)
charlotte.score.onNext(100)

/*
80
85
90
95
100
*/
Swift
복사

flatMapLatest

가장 최근에 넘어온 Observable 이벤트 값만 넘김

map과 switchLatest를 합한 형태로 항목을 하나의 Observable로 합치지 않습니다. 가장 최근에 들어온 Observable로 넘어가면서 자동적으로 이전 Observable 구독을 해지합니다.

let disposeBag = DisposeBag()
let a = BehaviorSubject(value: 1)
let b = BehaviorSubject(value: 2)
let subject = PublishSubject<BehaviorSubject<Int>>()

subject
    .flatMapLatest { $0.asObservable() }
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)

subject.onNext(a)
subject.onNext(b)

a.onNext(11)
b.onNext(22)
b.onNext(222)
a.onNext(111)

/*
1
2
22
222
*/
Swift
복사

flatMapFirst

처음 구독을 시작한 Observable의 이벤트만 넘김

flatMapLatest와 다르게 처음 구독을 시작한 Observable의 이벤트만 넘깁니다.

let disposeBag = DisposeBag()
let a = BehaviorSubject(value: 1)
let b = BehaviorSubject(value: 2)
let subject = PublishSubject<BehaviorSubject<Int>>()

subject
    .flatMapFirst { $0.asObservable() }
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)

subject.onNext(a)
subject.onNext(b)

a.onNext(11)
b.onNext(22)
b.onNext(222)
a.onNext(111)

/*
1
11
111
*/
Swift
복사

groupBy

이벤트를 분류해서 다른 Observable로 변형

groupBy를 사용하면 조건에 해당하는 요소들을 손쉽게 Grouping 가능합니다.

let disposeBag = DisposeBag()
let words = ["Apple", "Banana", "Orange", "Book", "City", "Axe"]

Observable.from(words)
    .groupBy { $0.count }
    .flatMap { $0.toArray() }
    .subscribe { print($0) }
    .disposed(by: disposeBag)

/*
next(["Banana", "Orange"])
next(["Axe"])
next(["Book", "City"])
next(["Apple"])
completed
*/
Swift
복사