RxSwift - Relay

Relay는 Subject를 랩핑하고 있는 클래스입니다. RxSwift6 에서는 세 가지의 Relay를 제공합니다. 

RxSwift에서 제공하는 클래스인 Subject와 다르게 Relay는 RxCocoa에서 제공하기 때문에 사용하려면 RxCocoa를 import 해야합니다.

 

Relay는 Subject와 같이 이벤트를 받아서 구독자에게 전달할 수 있다는 공통점을 가지고 있습니다.

하지만 Relay는 Subject와 달리 Completed와 Error 이벤트를 사용할 수 없고 Next 이벤트만 사용할 수 있다는 차이점이 있습니다.

Relay는 Dispose 되기 전까지 계속 작동하는 특징 때문에 주로 UI event 처리를 담당합니다.

 

Subject에서는 onNext 메소드를 통해 event를 전달했지만 Relay는 accept 메소드를 통해 이벤트를 전달합니다.

그럼 각 Relay를 코드를 통해 살펴보겠습니다.

 

PublishRelay

let bag = DisposeBag()
let publishRelay = PublishRelay<Int>()
// PublishRelay 생성

publishRelay.subscribe { print("publishRelay : \($0)") }
    .disposed(by: bag)
// PublishRelay 구독

publishRelay.accept(1)
// event 1 발생

// Result -------
//publishRelay : next(1)

// PublishRealy 구독 후 발생한 event1 전달받음

BehaviorRelay

let bag = DisposeBag()
let behaviorRelay = BehaviorRelay<Int>(value: 1)
// 초기값 1을 가진 behaviorRelay 생성

behaviorRelay.subscribe { print("behaviorRelay : \($0)") }
    .disposed(by: bag)
// behaviorRelay 구독

// Result -------
//behaviorRelay : next(1)
// behaviorRelay 구독 전 가지고 있던 초기값 1을 구독 즉시 전달받음

behaviorRelay.accept(2)
// event2 발생 및 저장된 값 2로 변경

// Result -------
//behaviorRelay : next(2)
// event2 발생 전 구독하고 있던 구독자에게 event2 즉시 전달

ReplayRelay

let bag = DisposeBag()
let replayRelay = ReplayRelay<Int>.create(bufferSize: 2)
// 버퍼사이즈가 2인 replayRelay 생성


replayRelay.accept(1)
replayRelay.accept(2)
// event1,2 발생 및 버퍼에 저장

replayRelay.subscribe { print("replayRelay : \($0)") }
    .disposed(by: bag)
// replayRelay 구독

// Result -------
//replayRelay : next(1)
//replayRelay : next(2)
// behaviorRelay 구독 전 버퍼에 저장된 event1,2를 구독 즉시 전달받음

replayRelay.accept(3)
// event3 발생 및 버퍼에서 가장 오래된 evnet1을 event3으로 대체

// Result -------
//replayRelay : next(3)
// 구독자에게 event3 발생 즉시 전달

 

참고 : Reactive Programming with Swift By the raywenderlich.com Tutorial Team