Subject와 Relay

import RxSwift // MARK: - PublishSubject // 구독이 이루어진 시점 이후의 새로운 이벤트만 구독자에게 전달함. // 초기값을 가지지 않음. let disposeBag = DisposeBag() let publishSubject = PublishSubject<String>() // "Hello" 이벤트를 방출하지만 현재 구독자가 없기 때문에 이 이벤트는 아무도 받지 못함. publishSubject.onNext("Hello") // 첫 번째 구독자 추가 publishSubject.subscribe(onNext: { print("Subscriber 1: \($0)") }).disposed(by: disposeBag) publishSubject.onNext("World") // 두 번째 구독자 추가 publishSubject.subscribe(onNext: { print("Subscriber 2: \($0)") }).disposed(by: disposeBag) publishSubject.onNext("RxSwift")

Subscriber 1: World Subscriber 1: RxSwift Subscriber 2: RxSwift

import RxSwift // MARK: - BehaviorSubject let disposeBag = DisposeBag() let behaviorSubject = BehaviorSubject<String>(value: "Initial Value") // 구독 즉시 "Initial Value" 출력 behaviorSubject.subscribe(onNext: { print("Subscriber 1: \($0)") }).disposed(by: disposeBag) // onNext 이벤트가 발생하면 해당 이벤트 전달 // 구독 중인 모든 구독자에게 "Hello" 전달 behaviorSubject.onNext("Hello") // 두 번째 구독자는 구독 즉시 가장 최근에 방출된 "Hello" 이벤트를 전달받음 behaviorSubject.subscribe(onNext: { print("Subscriber 2: \($0)") }).disposed(by: disposeBag) // 구독 중인 모든 구독자에게 "World" 전달 behaviorSubject.onNext("World")

Subscriber 1: Initial Value Subscriber 1: Hello Subscriber 2: Hello Subscriber 1: World Subscriber 2: World

import RxSwift // MARK: - ReplaySubject // 버퍼 크기를 설정하여 새 구독자가 구독할 때 설정된 크기만큼의 최근 이벤트를 전달함. let disposeBag = DisposeBag() // 버퍼 크기를 2로 설정 // 항상 마지막 두 개의 이벤트를 버퍼에 저장 let replaySubject = ReplaySubject<String>.create(bufferSize: 2) // 버퍼의 크기가 2이기 때문에 "1"은 버퍼에서 제거 replaySubject.onNext("1") // "2"와 "3"만 버퍼에 저장 replaySubject.onNext("2") replaySubject.onNext("3") // 'Subscriber 1'이 ReplaySubject를 구독 // 구독 시점에 버퍼에 있는 이벤트("2", "3")가 'Subscriber 1'에게 즉시 전달 replaySubject.subscribe(onNext: { print("Subscriber 1: \($0)") }).disposed(by: disposeBag) // 이후 방출되는 이벤트도 전달 // 하지만 버퍼 크기가 2이기 때문에 가장 오래된 값인 "2"가 제거되고 "3"과 "4"가 저장 replaySubject.onNext("4") // 'Subscriber 2'가 구독한 시점에 버퍼에 있는 이벤트를 즉시 전달 // 따라서 "3"과 "4"가 출력 replaySubject.subscribe(onNext: { print("Subscriber 2: \($0)") }).disposed(by: disposeBag)

Subscriber 1: 2 Subscriber 1: 3 Subscriber 1: 4 Subscriber 2: 3 Subscriber 2: 4

import RxSwift // MARK: - AsyncSubject // AsyncSubject는 일반적인 Subject와는 달리, // Observable이 완료되었을 때 마지막으로 발행된 값을 구독자에게 전달함. let disposeBag = DisposeBag() let asyncSubject = AsyncSubject<String>() // 구독자 1은 이후에 발행된 값과 // 완료 이벤트가 발생할 때의 마지막 값을 받을 준비가 됨 asyncSubject.subscribe(onNext: { print("Subscriber 1: \($0)") }).disposed(by: disposeBag) // "1"과 "2" 값을 발행 // 하지만 이 시점에서는 완료 이벤트가 발생할 때까지 어떤 구독자에게도 값이 전달되지 않음 asyncSubject.onNext("1") asyncSubject.onNext("2") // 구독자 2도 마지막 값을 받을 준비가 됨 asyncSubject.subscribe(onNext: { print("Subscriber 2: \($0)") }).disposed(by: disposeBag) // 이 값은 현재까지 발행된 마지막 값이지만 아직 두 구독자에게 전달되지 않음 asyncSubject.onNext("3") // 완료 이벤트 발행 // 이 시점에서 마지막으로 발행된 "3"을 모든 구독자에게 전달됨 asyncSubject.onCompleted()

Subscriber 1: 3 Subscriber 2: 3

import RxCocoa import RxSwift // MARK: - BehaviorRelay // 주로 상태를 관리하거나 UI와 데이터 사이의 연결고리 역할을 하는데 유용함. let disposeBag = DisposeBag() let behaviorRelay = BehaviorRelay<String>(value: "Initial Value") // 현재 구독자가 없기 때문에 출력은 없음 // onNext와 유사하지만 onCompleted나 onError 이벤트를 발행하지 않음 behaviorRelay.accept("Hello") // 구독하여 값이 변경될 때마다 실행되는 클로저 설정 behaviorRelay.subscribe(onNext: { print("Subscriber 1: \($0)") }).disposed(by: disposeBag) // 현재 구독자가 있으므로 출력 behaviorRelay.accept("World")

Subscriber 1: Hello Subscriber 1: World

import RxCocoa import RxSwift // MARK: - PublishRelay let disposeBag = DisposeBag() // 초기값을 가지지 않음 let publishRelay = PublishRelay<String>() // 구독자가 없기 때문에 출력되지 않음 publishRelay.accept("Hello") publishRelay.subscribe(onNext: { print("Subscriber 1: \($0)") }).disposed(by: disposeBag) publishRelay.accept("World")

Subscriber 1: World