[ RxSwift ] Subject를 알아보자

이미지 클릭 시 공식문서로 이동

 

🔎  1 . Subject

---

Subject는 다리, 프록시 역할로 데이터의 중계 역할을 하는 객체이다. 

데이터를 받아서 구독자들에게 재전송하거나 새로운 데이터를 직접 발행한다. 

 

따라서, Subject는 옵저버이면서 동시에 옵저버블이다. 

Subject는 하나 이상의 다른 옵저버블을 구독할 수 있고(옵저버 역할), 동시에 옵저버블이므로 구독자에게 데이터를 전달할 수 있다.  

* 옵저버블은 다른 옵저버블을 구독하지 못한다. 옵저버도 다른 옵저버에게 이벤트를 전달하지 못한다. 

 

 

 

 

🔎  2. Subject의 종류

---

Subject는 .next 이벤트를 받고, 이벤트를 수신할 때마다 구독자에게 방출한다. 

기본적으로 옵저버블은 cold 옵저버블로 동작하기 때문에 구독자가 새로운 값을 받을 때마다 처음부터 이벤트를 다시 생성한다. 

하지만 여러 구독자에게 동일한 데이터 스트림을 공유해야하는 상황에서는 Subject를 이용해

하나의 스트림을 여러 구독자에게 동시에 제공할 수 있다. 

 

Subject를 사용해 하나의 이벤트 스트림을 두개의 구독자가 공유

import RxSwift

let disposeBag = DisposeBag()

// PublishSubject 생성
let subject = PublishSubject<String>()

// 첫 번째 구독자
subject.subscribe(onNext: { value in
    print("첫 번째 구독자가 받은 값: \(value)")
}).disposed(by: disposeBag)

// 두 번째 구독자
subject.subscribe(onNext: { value in
    print("두 번째 구독자가 받은 값: \(value)")
}).disposed(by: disposeBag)

// 외부에서 이벤트 방출
subject.onNext("공유된 이벤트 1")
subject.onNext("공유된 이벤트 2")

 

 

*아래 코드 예시를 이해할 때 참고*

버튼 클릭 이벤트를 처리할 때, 버튼 클릭 시 데이터를 처리하는 코드가 구독자 역할을 하게 된다. 

버튼을 클릭하면 onNext로 이벤트가 발생하고 그걸 구독자(onNext 클로저 부분)가 받아서 처리하는 구조이다. 

 

1. PublishSubject

구독이 시작된 이후 발생한 이벤트만 구독자에게 방출한다. 

구독을 멈추거나 .completed, .error 이벤트를 통해 Subject가 종료될 때까지 지속된다. 

 

적합한 상황

- 이전의 이벤트는 중요하지 않은 경우 

- 구독을 시작한 이후부터 발생하는 이벤트만 받고 싶을 때

- 예시) 버튼 클릭 이벤트처럼 과거에 버튼을 누른 기록은 중요하지 않고, 구독이 시작된 이후에 발생한 클릭 이벤트만 다루고 싶을 때 

 

let publishSubject = PublishSubject<String>()

// 1.Subject가 이벤트를 발생시키면(onNext를 호출하면)
publishSubject.onNext("이벤트 1")  // 옵저버블이 구독자에게 이벤트를 방출하지만 아직 구독자가 없기 때문에 전달되지 않음

// 2.구독자가 그 이벤트를 받아서 처리(onNext 클로저가 호출됨) 
// 3.value에 이벤트가 전달되고, print() 실행
publishSubject.subscribe(onNext: { value in  // onNext 클로저 부분이 구독자(subscriber)
    print("받은 이벤트: \(value)")
})

publishSubject.onNext("이벤트 2")  // 구독 후 이벤트만 전달됨


// 구독 전인 이벤트1은 무시되고 구독 이후인 이벤트2만 전달됨.

 

 

사용자가 버튼을 눌렀을 때 이벤트를 발생시키려면, 버튼의 액션과 onNext 메서드를 연결해야한다. 

버튼을 누르면 그 순간에 onNext가 호출되고 그로인해 이벤트가 발생한다. 

 

버튼을 누르는 흐름:

버튼 클릭 시 → button.rx.tap이 감지 → subject.onNext("버튼이 눌렸습니다!")가 호출됨 → subject의 구독자가 그 이벤트를 받아서 print로 출력함.

 

import UIKit
import RxSwift
import RxCocoa

class ViewController: UIViewController {
    let disposeBag = DisposeBag()
    let subject = PublishSubject<String>() // Subject 생성

    override func viewDidLoad() {
        super.viewDidLoad()

        // 버튼 생성 및 설정
        let button = UIButton(type: .system)
        button.setTitle("이벤트 발생", for: .normal)
        button.frame = CGRect(x: 100, y: 100, width: 200, height: 50)
        self.view.addSubview(button)

        // 버튼 클릭 시 Subject에 이벤트 발생 (onNext 호출)
        button.rx.tap // 버튼을 Rx로 변환하여 클릭 이벤트를 감지
            .subscribe(onNext: { [weak self] in
                self?.subject.onNext("버튼이 눌렸습니다!")
            })
            .disposed(by: disposeBag)

        // Subject 구독 설정 (이벤트가 발생하면 처리)
        subject.subscribe(onNext: { value in
            print("받은 이벤트: \(value)")
        }).disposed(by: disposeBag)
    }
}

 

 

 

 

2. BehaviorSubject

하나의 초기값을 가진 상태로 시작하여, 새로운 구독자에게 초기값 또는 최신값을 방출한다. 

 

적합한 상황

- 구독자가 이전에 발생한 가장 최근의 데이터도 필요로 한 경우

- 예시) 사용자의 현재 상태나 설정 값처럼 과거의 마지막 값이 중요할 때.

           구독자가 필요할 때마다 가장 최신의 값을가져와야할 때

 

let behaviorSubject = BehaviorSubject(value: "초기값")

// 초기값을 설정했지만 곧바로 이벤트1이 발생하면서 초기값 덮어쓰여짐.
behaviorSubject.onNext("이벤트 1")  // 이벤트1 방출. 구독자가 없으므로 일단 기억만 하고 있음

behaviorSubject.subscribe(onNext: { value in
    print("받은 이벤트: \(value)")     // 구독자가 생기자마자 마지막으로 기억한 값인 이벤트1을 바로 구독자에게 전달.
})

behaviorSubject.onNext("이벤트 2") // 이벤트2가 구독자에게 전달됨


//출력 결과
받은 이벤트: 이벤트 1
받은 이벤트: 이벤트 2


===============================
let behaviorSubject = BehaviorSubject(value: "초기값") // 초기값 설정

// 구독자가 생기면 초기값을 전달
behaviorSubject.subscribe(onNext: { value in
    print("받은 이벤트: \(value)")
})

// 이제 onNext를 호출하여 추가 이벤트 방출
behaviorSubject.onNext("이벤트 1")
behaviorSubject.onNext("이벤트 2")

//출력 결과
받은 이벤트: 초기값
받은 이벤트: 이벤트 1
받은 이벤트: 이벤트 2


===============================

let disposeBag = DisposeBag()

// 초기 값을 가진 BehaviorSubject 생성
let subject = BehaviorSubject(value: "초기 값")

// 첫 번째 구독자가 구독
subject.subscribe(onNext: { value in
    print("첫 번째 구독자가 받은 값: \(value)")
}).disposed(by: disposeBag)

// 새로운 값 방출
subject.onNext("새로운 값 1")

// 두 번째 구독자가 구독 (이전 값인 '새로운 값 1'을 받게 됨)
subject.subscribe(onNext: { value in
    print("두 번째 구독자가 받은 값: \(value)")
}).disposed(by: disposeBag)

 

 

3. ReplaySubject

옵저버가 구독을 시작한 시점과 관계 없이 옵저버블이 배출한 모든 항목들을 모든 구독자에게 방출한다. 

구독자가 생긴 이후에도 지정된 버퍼의 크기만큼 이전에 방출된 이벤트를 다시 방출한다.

이로 인해 새로운 구독자가 지정된 범위 내에서의 이전 값을 받을 수 있다. -> 데이터를 캐시해야 할 때 유용함.

버퍼의 크기가 초과되면 가장 오래된 값부터 삭제된다. 

 

적합한 상황

- 검색창에서 최근 5개의 검색어를 보여주고 싶을 때

 

let disposeBag = DisposeBag()

// 2개의 버퍼를 가진 ReplaySubject 생성
let subject = ReplaySubject<String>.create(bufferSize: 2)

// 두 개의 값을 방출
subject.onNext("이전 값 1")
subject.onNext("이전 값 2")
subject.onNext("이전 값 3")

// 새로운 구독자가 구독 (가장 최근의 두 개 값만 받음)
subject.subscribe(onNext: { value in
    print("구독자가 받은 값: \(value)")
}).disposed(by: disposeBag)


// 출력 결과
구독자가 받은 값: 이전 값 2
구독자가 받은 값: 이전 값 3


/* ReplaySubject는 최대 2개의 이벤트를 캐싱하고 있음. 
새로운 구독자는 마지막 두 개의 이벤트만 받음.
데이터를 일부분 캐시하고 새로운 구독자에게 제공해야 할 때 유용 */

 

 

 

 

4. AsyncSubject

작업이 완료된 후에만 마지막 값을 전달한다. 

onCompleted가 호출된 후에만 마지막 이벤트를 전달한다. 

 

적합한 상황

- 결과가 완료된 후에만 특정 값을 전달해야할 때 

- 예시) 복잡한 계산이 끝난 후 그 결과만 전달하는 상황, 네트워크 요청이 끝났을 때 최종 응답 데이터만 전달하는 상황 

 

let disposeBag = DisposeBag()

let subject = AsyncSubject<String>()

subject.subscribe(onNext: { value in
    print("구독자가 받은 값: \(value)")
}).disposed(by: disposeBag)

// 여러 개의 값을 방출하지만 완료 전까지 구독자는 값을 받지 않음
subject.onNext("이벤트 1")
subject.onNext("이벤트 2")

// 완료 이벤트가 발생해야 구독자가 마지막 값을 받음
subject.onCompleted()


// 출력결과
구독자가 받은 값: 이벤트 2

 

 

 

 

 

 

 

 

 

 

 

🔗 Reference 

https://github.com/fimuxd/RxSwift/blob/master/Lectures/03_Subjects/Ch3.%20Subjects.md