[RxSwift] DisposeBag 과 Operator

observable은 subscription되기 전까지 아무런 이벤트도 방출할 수 없다 -> 아무것도 할 수 없음

subscription이 옵저버블이 동작하도록 새로운 이벤트를 방출하도록 하고 .error 혹은 .completed 이벤트를 방출하게 하며 종료시키게 하는 트리거 같은 역활을 하는 것!

그렇다면 더이상 옵저버블이 필요 없어지거나 더 이상 이벤트를 방출하고 싶지 않다! 할 때는 유튜브 처럼 구독 취소 할 수 있음

이걸 수행 하는 것이 Disposing의 개념이고 observable은 즉시 종료된다!

 

$0을 default argument라고 부르는 걸 처음 알았당. 책에서의 표현인가?

 

let disposeBag = DisposeBag()

이렇게 DisposeBag을 생성하여 한번에 관리가 가능하다

observable을 구독하는 subscribe는 리턴으로 Disposable을 반환한다. DisposeBag은 이러한 Disposable을 담아 할당해제시 각각에 대해 dispose() 를 호출 할 수 있음

 

왜 dispose를 해줘야 하냐면 메모리 누수가 일어날 수 있기 때문이다 아직 많이 배우지 않아서 잘 모르겠는데 아마도 이걸 다른 곳에서 사용할 수 있나보다 그래서 메모리에서 해지하고 할당하는 것을 개발자에게 dispose로 제공하는 것 같은데 다행히 swift compiler가 어느정도 알려준다고 한다!

메모리 누수가 일어날 수 있는 상황은

DisposeBag에다가 subscribe를 추가하는 것을 잊었을 경우

subscribe를 마친 후 수동으로 삭제를 호출 <- 이건 무슨 뜻일까..

다른 point에서 observable이 종료되는 경우

 

오퍼레이터 공부하는데 도움을 주는 사이트

https://reactivex.io/documentation/operators.html

ReactiveX - Operators

 

create 오퍼레이터 

Observable을 생성하는 Operator

다른 것과 달리 직접적인 코드 구현을 통해 옵저버를 구현한다   subscribers에게 전송될 모든 '이벤트'를 정의할 수 있다.

subscribe 처럼 보이지만 Observable을 생성하기 때문에 subscriber 없이는 어떠한 이벤트도 방출되지 않는다! disposable을 직접 리턴해주어야 한다!

 

 Observable<String>.create { observer in
            // subscriber가 방출할 이벤트를 정의할 수 있음
            observer.onNext("cat")
            observer.onError(CustomError.testError)
            observer.onCompleted()
            observer.onNext("dog")
            return Disposables.create()
        }
        .subscribe { event in
            print(event)
        } onError: { error in
            print(error)
        } onCompleted: {
            print("create observable, Completed")
        } onDisposed: {
            print("create observable, Disposed")
        }.disposed(by: disposeBag)

        enum CustomError: Error {
            case testError
        }

create오퍼레이터에서  subscribe 파라미터의 인자로 넘겨준  subscribe 에서 직접적으로 코드 구현을 할 수 있음 (옵저버를 파라미터로 넘겨주는 것)

이를 통해서 옵저버 메서드를 호출하게 되는데 결과 값은 그래서 옵저버블! 생성된 값은 옵저버블 시퀀스이다

위에 코드에서 terminate 이벤트를 방출하는 걸 알 수 있는데 error을 호출하고  completed 이벤트를 방출하는 것을 볼 수 있다. 결과는 .completed 이벤트는 방출되지 않는데 .error 이벤트 방출된 후 바로 terminated 되기 때문이다! 

만약 terminate이벤트를 방출하지 않으면 절대 dispose 되지 않으므로 completed 이벤트나 disposeBag을 추가해 주면 된다

 

 

Observable 정의 후 다른 곳에서 subscribe 하면 내가 create에서 정의한 이벤트를 순서대로 방출 시킬 수 있고 terminate 시킬 수도 있는 것! 굉장히 좋은 기능이다! 왜 기존 프로젝트 생성할 필요 없이 리팩토링 해도 된다 한지 알것 같다. 적절한 곳에다가 rx로 로직 충분히 짤 수 있을 것 같다

 

Observable Factories

팩토리 함수를 사용하면 원하는 만큼의 많은 객체를 생성할 수 있다고 한다 Rx에서 팩토리는 인풋을 옵저버블로 변환시켜 주기 때문에 Operator로 간주된다

RxSwift에서 이 기능을 사용할 수 있는 오퍼레이터는 differ 로 구현되는데 인풋과 아웃풋이 기존에 봤던 오퍼레이터와 좀 다르다

반환값을 보면 observable이다 즉 옵저버블을 생성하는데 직접 옵저버블을 반환해 준다는 것

파라미터로는 observableFactory를 지정해 주어야 하는데 Observable 팩토리

 

미리 만들어진 Observable을 구독하는 것이 아닌 구독 시점에야 Observable을 만듬

전형적인 팩토리 함수란 --> subscribe 되기 전까지 기다렸다가 구독이 되면  Observable 생성 

출처 : ReactiveX

이 deferred 오퍼레이터로 생성된 Observable을 구독하는 subscribe 마다 deferred의 observableFatory로 전달한 것이 새롭게 실행되는 것, 즉 여러 구독자가 동일한 Observable에 가입하고 있다고 생각될 수 있으나 사실은 개별 시퀀스를 가짐 ( ⭐️⭐️⭐️⭐️⭐️)

그림에서 알 수 있듯이 각 subscribe 별로 다른 시퀀스를 가진다! 하나의 Observable을 가지고 똑같은 결과를 찍는 것이 아닌 개별 시퀀스!!

 

이쯤에서 시퀀스랑 Observable이 매우 헷갈리는데 Observable은 일련의 Sequence(순서)를 가지고 있고 이 순서대로 구독한 대상에게 이벤트를 전달하는 것

everything is sequence!

관찰자 패턴인 Observable<Element> 시퀀스와 일반적인 시퀀스의 개념이 같음

Observable은 일련의 순서대로 이벤트를 방출하게 되는데 그렇기에 Observable이  sequence와 같은 개념으로 쓰일 수 있는 것임

        let disposeBag = DisposeBag()
        var hasNewImageUpdated = false
        let factory: Observable<String> = Observable.deferred {
            hasNewImageUpdated.toggle()
            
            if hasNewImageUpdated {
                return Observable.of("image1.jpg", "image2.jpg")
            } else {
                return Observable.of("newUpdatedImage.jpg")
            }
        }
        
        for _ in 0...3 {
            factory.subscribe(onNext: { element in
                print(element, terminator: ", ")
            }).disposed(by: disposeBag)
            print()
        }

 

문제시 댓글로 알려주세요!!

 

 

참고 사이트 및 도서 : 

https://medium.com/tompee/rxjava-ninja-observable-factories-part-1-98c97f6db853