RxSwift (1) 주요 개념 (Observable , Subscribe, Disposable, Operator)

Observable

혹은 Observable Sequence , Sequence와도 같은 말이다. 관찰 가능한 객체이며, 구독자가 이를 구독하여 “이벤트”를 받을 수 있다. 이벤트에는 3가지 종류가 있다.

이벤트의 전달 방향 : Observable -> Observer
이벤트의 관찰 방향 : Observable <- Observer

이벤트의 종류

Observable은 3가지 이벤트를 구독자에게 전달하는데, 구독자는 이를 받아 해야할 일들을 처리한다.

• Next: Emission이라고도 하며, 원소(값)들을 방출한다.
• Completed: Observable이 “에러 발생 없이 정상적으로 종료될때” 전달된다. Observable의 생명주기가 끝난다.
• Error: Observable이 “에러로 인해 종료될때” 전달된다. Observable의 생명주기가 끝난다.

Marble Diagram

https://rxmarbles.com

Observable의 생성예시

1. Create 연산자를 이용한 생성

let observerble = Observable<Int>.create { (observer) -> Disposable in
    observer(50)
    observer(.next(100))
    observer()

    return Disposables.create()
}

2. From 연산자를 이용한 생성

let observerble2 = Observable<Int>.from([-50, -100])

SubScribe

Observable은 Observer에게 이벤트를 전달한다. 이 전달되는 시점은 observer가 observable을 subscribe하는 순간이다. 즉, 관찰(구독)을 하지 않으면 이벤트도 전달되지 않는다는 말과 같다.

let ob1 = Observable<Int>.create { (observer) -> Disposable in
   observer.on(.next(0)) // 구독자에게 0이라는 값을 전달한다.
   observer.onNext(1)  // 구독자에게 1이라는 값을 전달한다.
   observer.onCompleted() // Observable이 정상 종료되며, 생명주기가 끝난다.
   return Disposables.create()
}


ob1.subscribe { event in
   print(event.element) // 이렇게도 값에 접근할 수 있다.
    switch event{
    case .next(let element):
        print("element ->",element)
    case .completed:
        print("Completed!")
    case .error(let error):
        print(error)
    }
}

구독을 하게되면 Event를 전달받게되고, 위에서 말했듯이 3가지 종류가 있기 때문에 switch로 분기할 수 있다.
Switch문 밖에서 onNext로 전달받은 값에 직접 접근하려면 event.element 로 접근할 수 있다.

그리고 Subscribe(관찰)을 통해 전달받는 이벤트는 한번에 하나의 이벤트만 전달받게된다.

Disposable

Observable과 관련된 리소스를 정리하는 코드

var bag = DisposeBag()

let ob = Observable.from([1,2,3])
    .subscribe { element in
        print("onNext: \(element)")
    } onError: { error in
        print("Error: \(error)")
    } onCompleted: {
        print("onCompleted")
    } onDisposed: {
        print("Disposed")
    }.disposed(by: bag)

bag = DisposeBag() 

여기서 Disposed는 Observable이 전달하는 이벤트가 아니다. Observable과 관련된 모든 리소스가 제거된 후에 Disposed 클로저가 호출된다.

Disposable 용도

• Observable과 관련된 리소스들을 정리하는데 사용된다.
• 실행 취소에 사용된다.

만들어놨던 DisposeBag 프로퍼티에 새로운 DisposeBag를 넣으면 bag안에 있던 Disposable들이 해제된다.
또는 옵셔널로 해서 nil을 넣어줘도 같은 결과를 만들 수 있다.

Disposable을 실행취소에 사용하는 경우

// 실행 취소에 사용되는 경우
let ob2 = Observable<Int>
    .interval(.seconds(1), scheduler: MainScheduler.instance)
    .subscribe { element in
        print("onNext: \(element)")
        if element == 3{
            bag = DisposeBag()
        }
    } onError: { error in
        print("Error: \(error)")
    } onCompleted: {
        print("onCompleted")
    } onDisposed: {
        print("Disposed interval")
    }.disposed(by: bag)

Operators (연산자)

Observable을 생성, 방출, 필터링 등의 다양한 메서드들이 있는데 이것들을 통틀어 Operators라고 한다.
Map, filter, take….. 등 꽤 여러종류가 있다. 마블 다이어그램을 통해서 시각적으로 확인할 수 있다.
RxMarbles: Interactive diagrams of Rx Observables

Take operator

Observable.from([1, 2, 3, 4, 5, 6, 7, 8, 9])
    .take(5)
    .subscribe { print($0) }
    .disposed(by: bag)

Take operator는 emit을 5회 실행한다.