[RxSwift] Observable.create의 동작원리 이해하기

Observable.create

Observable을 사용하면서 진짜 많이 쓰는 create 메서드가 어떻게 동작하는지 알아보려고 합니다. 일반적으로 create에 클로저를 전달하고 Observable을 반환받습니다. 

let observable = Observable<Int>.create { observer in
    observer.onNext(1)
    observer.onCompleted()
    return Disposables.create()
}

observable.subscribe(...)

이런식으로 사용했었죠. 그럼 어떤 과정으로 Observable이 생성되는지 알아봅시다!

 

개인적으로 RxSwift를 간략하게 코드로 옮긴 저장소를 만들었는데요, 내부적으로 원자적연산이나 확장성에 대한 지원이 부족하지만 핵심적인 로직을 이해하고자 했습니다. 이 포스트에서는 이 레포에 있는 코드를 따라가면서 확인해보려고 해요.

GitHub - jeonyeohun/Understanding-RxSwift-Internals: 읽다보면 이해가 되는 알엑스 👀

실제 저장소인 RxSwift 의 코드와 핵심 로직은 완전히 똑같기 때문에 비교하면서 봐도 괜찮을거에요! 그럼 시작하겠습니다!

 

예제 코드를 따라가자

let observable = Observable<Int>.create { observer in
    observer.onNext(1)
    observer.onCompleted()
    return Disposables.create()
}

observable.subscribe(...)

이 코드를 실행하면 순서대로 어떤 일들이 일어나는지 확인해보겠습니다.

먼저 create 메서드를 확인해보겠습니다. 

 

create는 Observable이 아니라 ObservableType의 타입메서드로 정의되어 있습니다.

Observable을 열어보면 ObservableType 프로토콜을 채택하고 있어요. 우리가 create로 불렀던 메서드는 Observable의 메서드가 아니라 ObservableType의 타입메서드였던 것이죠. 

 

다시 이 코드를 볼게요! create는 subscribe라는 이름의 escaping closure를 받고 있어요. 이 클로저는 AnyObserver를 인자로 받고 Disposable을 반환하는 클로저입니다. 

 

create를 할 때 전달했던 클로저를 다시 볼까요?

{ observer in
    observer.onNext(1)
    observer.onCompleted()
    return Disposables.create()
}

이 클로저인데, observer라는 입력을 받아서 observer의 onNext 메서드와 onCompleted 메서드를 실행하고, 마지막에는 Disposables.create() 를 통해서 Disposable을 반환하는 클로저입니다.

 

create 메서드에서는 이 클로저를 그대로 사용하지 않고 AnonymousObservable의 생성자에 클로저를 그대로 넘겨주고 있습니다. 그리고 AnonymousObservable이 create의 결과로 반환되고 있습니다.

 

AnonymousObservable이 어떤 클래스인지 확인을 해봐야겠네요. AnonymousObservable를 열어봅시다!

 

AnonymousObservable안에는 생성자도 있고, run이라는 메서드도 있습니다. 그런데 아직 run을 호출하는 코드는 만나지 못했으니까 흐름 그대로 생성자만 확인해볼게요.

 

생성자는 SubscribeHandler 타입을 인자로 받아서 subscribeHandler 프로퍼티에 할당해주고 반환됩니다. 그리고 SubscribeHandler는 아까 보았던 create의 파라미터 타입과 동일한 (AnyObserver) -> Disposable 입니다.

 

그럼 결국 우리가 전달한 클로저가 AnonymousObservable의 subscribeHandler에 저장되고, 이 AnonymousObservable의 인스턴스가 create 메서드의 결과로 반환된다고 할 수 있습니다.

 

정리

create는 끝났습니다ㅎㅎ create는 사실 단순하고, subscribe를 봐야 이렇게 만든 AnonymousObservable을 어떻게 사용하는지 알 수 있을 것 같아요. 일단 지금까지 본 내용을 정리해봅시다!

 

1) 먼저 create 메서드를 호출하면서 클로저를 전달합니다.

2) create 메서드는 ObservableType에 정의되어 있고, 구현은 AnonymousObservable 인스턴스를 생성해 반환하도록 작성되어있습니다.

3) AnonymousObservable을 생성할 때는 create를 호출하며 전달한 클로저가 subscribeHandler에 저장이 됩니다. 

 

간단하죠?

 

다음 포스트에서는 subscribe의 동작원리를 보려고 해요. 읽어주셔서 감사합니다!