[RxSwift] 개념잡기 (Subscribe, Observable, Subject)

 

 

 

 

최대한 간단하게 설명해보는 RxSwift

 

 

iOS 공부하는 사람은 무조건 들어봤을 RxSwift

RxSwift는 ReactiveX Swift인데요,

 

reactiveX ?

대충 해석하면 옵저버블을 사용해서 비동기나 event-based를 구성하는 것이다

옵저버블이 뭔데 ?????

 

Observable ?

대충 해석하면

- 옵저버는 옵저버블을 구독한다
- 옵저버는 옵저버블이 방출하는 items에 대해 반응한다
- 옵저버는 대기하지 않고, 반응할 준비를 한 어떠한 형태로 기다린다

 

items이 어떤건지는 몰라도 일단 옵저버는 옵저버블이 뭔가를 하면 반응한대!!

옵저버가 무슨 형태인지는 몰라도 일단 대기 ㄴㄴ 즉, sync ㄴㄴ

 

많은 용어들이 나오는데 Observer, Observable, Subscribe

근데 이 용어들이 Rx의 시작과 끝이다!

옵저버가 옵저버블을 구독!! 하는데 우리는 이 구독!! 이 뭔지를 알아야 합니다. 이게 포인트임

 

RxSwift Concept

우리 youtube에서 구독이라는 것을 하잖아요?

구독을 하면 일어나는 일을 🦶로 그려보았어요

 

나는 구독자 즉, 옵저버에요

옵저버는 옵저버블을 구독한다고 했죠? 그럼 제니가 옵저버블이 되겠네요

다시 나타내면,

 

엥?? 갑자기 onNext()? 라고 생각할 수 있는데 이제부터 살펴볼게요..ㅎㅎ

 

우리가 유튜브에서 구독하는 방법은 구독 버튼 누르는 거죠

RxSwift에서 옵저버블을 구독하는 방법은,

Observable.subscribe(event)

우리가 구독버튼을 누르고 바라는것은 "새 영상이 업로드 되면 알림" 이겠죠?

Observable를 구독할 때 바라는 점은 저기 event 자리에 클로저 형태로 우리가 직접!! 작성할 수 있어요

 

그럼 Observable이 이제 이벤트를 방출해야겠죠? 영상 업로드와 같은 행위를요!

그때의 Observable을 코드로 나타내면 다음과 같아요

var jennie : Observable<String> = Observable.create { observer in
    observer.onNext("새로운 영상 업로드")

    return Disposables.create()
}

 

아까 위에 그림에서 새로운 영상 업로드 -> onNext()로 바뀌었잖아요!

observer.onNext()라고 하면 옵저버에게 이벤트를 전송하는거에요! 내가 지금 뭔가 바뀌었다는 것을요!!

이 코드는 "새로운 영상 업로드"라는 문자열을 옵저버에게 보낸다는 의미입니다

 

그럼 위에서 말한 subscirbe에 제니를 구독했을 때의 행위를 자세히 작성해 보도록 하겠습니다

jennie.subscribe(onNext: {
    print("\($0)")
}).disposed(by: disposeBag)

disposed()는 놔두고 해석하면

제니를 구독할건데 onNext()이벤트가 오면 데이터를 print를 해줘

라는 의미가 됩니다!!

여기서는 "새로운 영상 업로드" 문자열이 오면 print를 해줘라고 해석할 수 있겠죠?!

실행해보면 subscribe하자마자 바로 새로운 영상 업로드가 print 돼요..?

구독 버튼을 누르면 subscribeJennie()실행

UI 코드는 본문과 별로관계가 없어서 생략할게요 ㅎㅎ!

???

뭔가 이상하지 않나요 ???

제니가 나중에 영상을 업로드 할 수도 있는데 제니를 구독하자마자 새로운 영상을 업로드 했다고 하잖아요?!

그 이유는 create안에 onNext를 작성했기 때문이에요

제니를 구독을 하자마자 create안에 있는 onNext()가 실행되는 거죠!

간단하게 말하면,

subscribe() -> create안에 작성한 내용 실행 !!

근데 Obervable은 그렇게 만들잖아.. create안에 onNext()가 있는거잖아... 밖에 있을 수가 없잖아...

근데 구독은 항상 바로바로 실행되면 안되는거잖아!

 

그럼 delay하면 되잖아!

var jennie : Observable<String> = Observable.create { observer in
    DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() + 3 ) {
        observer.onNext("새로운 영상 업로드")
    }
    return Disposables.create()
}

이렇게 쓰면 구독하고 3초뒤에 새로운 영상을 무조건 업로드 하는거잖아요.. 정해진 시간 말고 제니가 업로드 하고 싶을때 해주란 말이야

 

Subject

우리는 subject를 사용해서 나중에!!! 새로운 영상 업로드를 하게 할 수 있어요

 

subject에는 다양한 종류가 있는데 그 중에서 PublishSubject를 써볼게요

왜냐하면 유튜브 구독 원리랑 매우 비슷하거든요 ㅎㅎㅎ

그림을 보면 알겠지만 구독한 시점부터 발생한 데이터만 전달을 하는거에요! 

 

var jennie : PublishSubject<String> = PublishSubject()

 

 

구독하는 코드는 똑같아요

그리고 upload버튼을 하나 만들어 줄게요

(UI 코드는 알아서..ㅎㅎ)

버튼은 이렇게 동작할거에요

@objc func tapButton() {
    jennie.onNext("새로운 영상 업로드") //Observable외부에서 onNext()실행
}

 

그러면!! 구독하고, 버튼을 눌렀을 때 새로운 영상 업로드가 나타나게 되겠죠 ?!

구독 안하면 버튼 눌러도 안나와요

 

 

Observable은 누군가 나를 구독하면 create안에 onNext()가 바로 실행되지만,
Subject는 구독해둔 채로 있다가 onNext()가 외부에서 나중에 실행될 수 있다는거

 

 

위에 있던 그림에서 Observable -> Subject 해줄게요

 

이제 이 그림이 대충.. 이해가 될까요 ..?

본격적인 Rx는 시작도 안한거지만 느낌만 알아보고 가는걸로 해요 🙃

 

 

틀린내용이나 피드백있으면 댓글 남겨주시면 감사하겠습니다 :)