오늘은 모두가 쓰지만 저만 안쓰고 있던 RxSwift가 무엇이고, 어떻게 쓰는건지 알아보겠습니다.

우선 RxSwift는 Swift만 갖고 있는 라이브러리는 아닙니다. 원래의 프로젝트 명은 ReactiveX이고 이 이름으로는 어디선가 들어봤던 것 같기도 하죠. RxSwift는 이 ReactiveX를 Swift에 이식한 버전의 이름입니다.

Reactive X

그렇다면 ReactiveX는 무엇일까요?

보통 우리가 짜는 코드는 동기적(Synchronous) 으로 실행됩니다. 우리가 적은 윗 줄부터 아래 줄까지 순서대로 한 번에 한 줄씩 차근차근 실행되죠. 하지만 ReactiveX에서는 작업들을 우선 병렬(parallel)적으로 실행 하고, ”observers” 라는 놈들로 나중에 결과물을 받아옵니다.

ReactiveX에서 작업은 아래 구조로 실행됩니다.

Observable ⬅️ Subscribe ◀️ Observer

Observable에서 어떤 행동이 포착되면 Observer는 그에 맞는 반응을 보내줍니다.

Observable

Observable 발행

비동기성(Asynchronous) 모델의 흐름은 아래와 같습니다.

1. 비동기성 호출의 return 값을 활용하여 method를 정의한다: Observer의 일부분
2. 비동기성 호출을 정의한다: Observable
3. Observer를 Observable에 연결한다: Subscribe
4. return value와 value를 활용한다.

def myOnNext = { it -> do something useful with it };
def myObservable = someObservable(itsParameters);
myObservable.subscribe(myOnNext);

onNext, onCompleted, onError

Subscribe된 Observer는 상황에 따라 subset을 가집니다.

onNext

Observable이 어떤 정보를 내보내면, onNext method의 인자로 받아옵니다.

onError

예상한 데이터를 생성하는 데 실패하거나 에러가 발생하면 onError method를 호출합니다. onError method를 호출한 이후에는 onNext, onCompleted method를 호출하지 않습니다. onError method의 인자로는 무엇이 에러를 일으켰는지 받아옵니다.

onCompleted

에러가 발생하지 않았을 때, 마지막 onNext method를 호출한 후에 호출됩니다.

정리해보면, onNext는 여러번 발생할 수도 있지만 onError와 onCompleted는 좋든 싫든 한 번만 발생하게 됩니다!

def myOnNext     = { item -> /* do something userful with item */ };
def myError      = { throwable -> /* react sensibly to a failed call */ };
def myComplete   = { /* clean up after the final response */ };
def myObservable = someMethod(itsParameters);
myObservable.subscribe(myOnNext, myError, myComplete);

Unsubscribing

Observable이 더 이상 모니터링이 필요 없어질 경우, subscribe를 해제할 수도 있습니다.

Observable이 unsubscribe 되면, 새로운 방출값을 생성하는 것을 멈출 수도 있습니다.

그런데 주의할 점은, 이 과정은 약간의 딜레이가 발생할 수 있기 때문에 방출값이 조금 더 생성된 후에 멈출 수도 있습니다.

Hot & Cold Observables

Hot Observable

생성됨과 동시에 방출값이 생성됩니다. Subscribe하는 Observer는 중간값부터 값을 받아가게 됩니다.

Cold Observable

Subscribe 되면, 그때부터 방출값이 발생합니다. 때문에 Subscribe하는 Observer는 생성된 모든 값을 받아갈 수 있습니다.

Operators

Chaining Operators

거의 대부분의 operator들은 Observable 안에서 작동하고, Observable을 반환하기 때문에 서로가 서로에게 연결되어 일종의 체인을 만들 수 있습니다.

이때 Operator들 간의 chain은 독립적으로 시행되지 않습니다. 연결된 순서에 따라 순서대로 하나씩 시행되게 됩니다.

Operators by Category

공식 문서를 보면 각 operator의 기능을 카테고리화 하여 분류해두었는데, 이를 한 번씩 살펴보며 정리해보겠습니다!

Creating Observables

• create

Observable을 생성할 수 있습니다.

let source: Observable = Observable.create { observer in
  for i in 1...5 {
    observer.on(.next(i))
  }
  observer.on(.completed)

  return Disposables.create {
    print("disposed")
  }
}

next(1)
next(2)
next(3)
next(4)
next(5)
completed
disposed

• just

간단하게 어떤 하나의 값을 Observable로 만들고 싶을 때 사용합니다.

let source = Observable.just(1, 2, 3)
let source2 = Observable.just([1,2,3])

1, 2, 3
[1, 2, 3]

• from

여러개의 값이 있고 각각을 Observable로 만들고 싶을 때 사용합니다.

let numbers = [1,2,3,4,5]
let source = Observable.from(numbers)

1
2
3
4
5

• of

여러개의 값을 Observable로 만들고 싶을 때 사용합니다.

from과 just의 중간 정도로 생각하면 됩니다.

배열을 사용했을 때는 배열 그대로 방출하고, 아닐때는 각각의 값을 하나씩 방출합니다.

let source = Observable.of(1, 2, 3)
let source2 = Observable.of([1, 2, 3])

1
2
3
1, 2, 3

Transforming Observables

• map

각각의 값을 원하는 형태로 변환하여 Observable로 만들고 싶을 때 사용합니다.

let source = Observable.from([1, 2, 3]).map { $0 * 2 }

2
4
6

• flatMap

각각의 Observable이 방출한 값에 대해 지정한 함수를 적용합니다. 이 떄, 각 함수는 자체적으로 값을 방출하는 Observalbe을 반환합니다.

let observableInt = Observable.of(1, 2, 3)
let observableString = Observable.of("A", "B", "C")

observableInt
  .flatMap { (x: Int) -> Observable<String> in
    return observableString
  }

next(A)
next(B)
next(A)
next(C)
next(B)
next(A)
next(C)
next(B)
next(C)
completed

• scan

let observable = Observable.of(1, 2, 3).scan(0) { $0 + $1 }

1
3
6

Filtering Observables

• filter

결과를 원하는 조건에 맞게 필터링하여 방출합니다.

let observable = Observable.from([1, 2, 3]).filter { $0 > 1 }

2
3

• first, last

결과 중 가장 첫번째/마지막을 방출합니다.

let observable = Observable.from([1, 2, 3]).first

Optional(1)

• take, takeLast

결과 중 마지막/처음부터 n번째까지 방출할지 정해서 방출합니다.

let observable = Observable.from([1, 2, 3]).takeLast(2)

2
3

• elementAt

n번째 인덱스의 결과를 방출합니다.

let observable = Observable.from([1, 2, 3]).elementAt(2)

3

Combining Observables

• merge

여러 Observable의 결과를 하나의 Observable로 합하여 반환합니다. 이 때, 하나의 Observable이라도 에러가 발생하면, 합쳐진 Observable도 종료됩니다.

let observableInt = Observable.of(1, 2, 3)
let observableInt2 = Observable.of(4, 5, 6)
let observableMerge = Observable.of(observableInt, observableInt2).merge()

1
2
4
3
5
6

• zip

각 Observable의 순서대로 짝을 맞추어 연산 결과를 방출합니다. 짝이 맞지 않는 값은 버립니다.

let observableInt = Observable.of(1, 2, 3, 4)
let observableString = Observable.of("A", "B", "C")
let observableZip = Observable.zip(observableInt, observableString) {
  "\($0)" + $1
}

1A
2B
3C

• combineLatest

각 Observable의 마지막 값끼리의 연산 결과를 방출합니다.

let observableInt = Observable.of(1, 2, 3)
let observableString = Observable.of("A", "B", "C")
let observableCombineLatest = Observable.combineLatest(observableInt, observableString) {
  "\($0)" + $1
}

1A
1B
2B
3B
3C