RxSwift - Subject & Relay

contents

🟣 Subject

🟣 Subject의 종류

Subject

Subject는 “Observable이자 Observer”라고 많이들 알고 있습니다.

이는 Observable로서 데이터를 태우고 다닐 Stream를 가지면서, Observer로서 데이터가 들어오는게 관찰되면 해당 데이터를 Stream에 태운다는 걸 뜻합니다.

이전에 얘기했던 RxSwift - Observable 은 생성된 Observable에 이미 넣어진 값만 보낼 수 있습니다. 하지만, 이런 경우가 생길 수 있습니다. 텍스트 필드에 있는 값이 변경되면 해당 값을 데이터로 보내주는 거죠. 텍스트 필드 값이 변경되기 전까지는 어떤 값으로 변경될 지 모르기 때문에 Observable에 해당 값을 미리 넘겨줄 수 없습니다. 값이 바뀌는지 관찰하고 있어야 하는겁니다.

이런 역할을 해줄 수 있는 것이 Subject입니다.

Subject를 생성해두면 텍스트 필드가 바뀔 때마다 그 값을 Subject Stream으로 방출하게끔하여 Observable에서 해결하지 못하는 문제를 해결할 수 있습니다.

Subject의 종류

PublishSubject

subscribe된 시점 이후부터 발생한 이벤트 전달

PublishSubject는 ⓵ 생성시 초기 값이 없는 Subject 입니다.

구독한 시점부터 이벤트가 발생하면 값을 받을 수 있고, Subject가 완전히 종료하고 나면 새로운 구독자가 생긴다고 해도 작동하지 않습니다. 종료 후엔 원래 구독하고 있던 구독자와 종료 이후 구독자 모두에게 종료 이벤트와 알림을 줍니다.

let 급식아줌마 = PublishSubject<String>()
let disposeBag = DisposeBag()

let 학생A = 급식아줌마
    .subscribe(onNext: { (food) in
        print("학생A가 냠냠 먹은 ",food)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생A 이제 끝")
    })
    .disposed(by: disposeBag)

급식아줌마.onNext("만두")
급식아줌마.onNext("치킨")
급식아줌마.onCompleted() // 아주머니 퇴근

let 학생B = 급식아줌마
    .subscribe(onNext: { (food) in
        print("학생B가 냠냠 먹은 ",food)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생B 이제 끝")
    })
    .disposed(by: disposeBag)

급식아줌마.onNext("스파게티")
급식아줌마.onNext("곱창")
급식아줌마.onNext("대방어")

/*
학생A가 냠냠 먹은  만두
학생A가 냠냠 먹은  치킨
학생A 이제 끝
학생B 이제 끝
*/
Swift
복사

BehaviorSubject

subscribe가 발생하면 즉시 현재 저장한 값을 이벤트로 전달

BehaviorSubject는 ⓵ PublishSubject와 비슷하지만 초기값을 가집니다.

BehaviorSubject를 subscribe하면 즉시 초기값을 이벤트로 전달하게 됩니다. 초기값이 없는 상태에서는 default값을 전달하고, 초기값이 있다면 최근값(항상 직전의 값부터 구독)을 전달합니다. 하지만, 초기값이 필요하지 않다면 그냥 PublishSubject를 사용하는게 좋습니다.

BehaviorSubject는 다른 Subject와는 다르게 ⓶ 마지막 이벤트 데이터를 저장하고 있습니다. 따라서, 값을 저장해두고 사용하고 싶을 때는 BehaviorSubject를 사용하면 됩니다.

let 급식아줌마 = BehaviorSubject(value: "대방어")
let disposeBag = DisposeBag()

let 학생A = 급식아줌마
    .subscribe(onNext: { (food) in
        print("학생A가 냠냠 먹은 ",food)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생A 이제 끝")
    })
        .disposed(by: disposeBag)

급식아줌마.onNext("소고기")
급식아줌마.onNext("피자")
급식아줌마.onNext("케이크")

let 학생B = 급식아줌마
    .subscribe(onNext: { (food) in
        print("학생B가 냠냠 먹은 ",food)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생B 이제 끝")
    })
        .disposed(by: disposeBag)

급식아줌마.onNext("샌드위치")
급식아줌마.onNext("요플레")

/*
학생A가 냠냠 먹은  대방어 /// default value 전달
학생A가 냠냠 먹은  소고기
학생A가 냠냠 먹은  피자
학생A가 냠냠 먹은  케이크
학생B가 냠냠 먹은  케이크 /// 최근 값 전달
학생A가 냠냠 먹은  샌드위치
학생B가 냠냠 먹은  샌드위치
학생A가 냠냠 먹은  요플레
학생B가 냠냠 먹은  요플레
*/
Swift
복사

ReplaySubject

n개의 이벤트를 저장하고 subscribe가 되는 시점과 상관없이 저장한 모든 이벤트를 전달

ReplaySubject는 ⓵ 구독 이전에 있었던 이벤트를 다 받을 수 있습니다. 생성 시에 선택한 특정 크기만큼 일시적으로 이벤트를 캐시하거나 버퍼에 저장해서 최신 요소를 모두 방출합니다.

⓶ 버퍼의 크기는 설정할 수 있으며, 만약 버퍼의 크기가 0이면 PublishSubject와 동일하게 작동합니다. 데이터 타입이 메모리를 크게 차지하는 값이라면 메모리 부하가 날 수도 있습니다.

ReplaySubject는 create(bufferSize: Int), createUnbounded 메소드를 가지는데, 어떤 메소드를 사용하느냐에 따라서 결과가 달라집니다.

•

create(bufferSize: Int)

let 구몬선생님 = ReplaySubject<String>.create(bufferSize: 2)
let disposeBag = DisposeBag()

구몬선생님.onNext("한자")
구몬선생님.onNext("수학")
구몬선생님.onNext("영어")

let 학생A의뇌 = 구몬선생님
    .subscribe(onNext: { (subject) in
        print("학생A가 배운 ",subject)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생A 이제 공부 끝")
    })
    .disposed(by: disposeBag)

let 학생B의뇌 = 구몬선생님
    .subscribe(onNext: { (subject) in
        print("학생B가 배운 ",subject)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생B 이제 공부 끝")
    })
    .disposed(by: disposeBag)

// 구몬선생님이 아이들에게 단단히 알려줄 수 있는 양이 2과목으로 한정
/*
학생A가 배운  수학
학생A가 배운  영어
학생B가 배운  수학
학생B가 배운  영어
*/
Swift
복사

•

createUnbounded

let 구몬선생님 = ReplaySubject<String>.createUnbounded()
let disposeBag = DisposeBag()

구몬선생님.onNext("한자")
구몬선생님.onNext("수학")
구몬선생님.onNext("영어")

let 학생A의뇌 = 구몬선생님
    .subscribe(onNext: { (subject) in
        print("학생A가 배운 ",subject)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생A 이제 공부 끝")
    })
    .disposed(by: disposeBag)

let 학생B의뇌 = 구몬선생님
    .subscribe(onNext: { (subject) in
        print("학생B가 배운 ",subject)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생B 이제 공부 끝")
    })
    .disposed(by: disposeBag)

// 구몬선생님이 아이들에게 무제한으로 알려줄 수 있지만 
// 학생들이 과부하에 걸려서 앓아 누울 수 있음
/*
학생A가 배운  한자
학생A가 배운  수학
학생A가 배운  영어
학생B가 배운  한자
학생B가 배운  수학
학생B가 배운  영어
*/
Swift
복사

AsyncSubject

completed될 때까지 아무런 이벤트를 발생하지 않다가, completed되면 마지막 이벤트를 전달하고 종료

AsyncSubject는 ⓵ completed되는 순간 마지막 이벤트를 전달하고 종료됩니다. 만약, 최근 전달된 next 이벤트가 없다면 그냥 completed 이벤트만 전달하고 종료되게 됩니다.

completed 이벤트 대신 error 이벤트를 전달할 경우 최근 next 이벤트가 전달되지 않고, error 이벤트만 전달되고 종료됩니다.

let 구몬선생님 = AsyncSubject<String>()
let disposeBag = DisposeBag()

구몬선생님.onNext("한자")
구몬선생님.onNext("수학")
구몬선생님.onNext("영어")

let 학생A의뇌 = 구몬선생님
    .subscribe(onNext: { (subject) in
        print("학생A가 배운 ",subject)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생A 이제 공부 끝")
    })
    .disposed(by: disposeBag)

let 학생B의뇌 = 구몬선생님
    .subscribe(onNext: { (subject) in
        print("학생B가 배운 ",subject)
    }, onError: { (error) in
        print("Erorr: ",error)
    }, onCompleted: {
        print("학생B 이제 공부 끝")
    })
    .disposed(by: disposeBag)

구몬선생님.onNext("구몬선생님의 맛집 리스트")
구몬선생님.onCompleted() // 구몬선생님 퇴근

/*
학생A가 배운  구몬선생님의 맛집 리스트
학생B가 배운  구몬선생님의 맛집 리스트
학생A 이제 공부 끝
학생B 이제 공부 끝
*/
Swift
복사

Relay

Relay는 Subject와 유사한 특징을 가지고 있는 타입입니다. 실제로 Relay 타입 내부에서 Subject를 래핑하고 있습니다.

public final class PublishRelay<Element>: ObservableType {
    private let subject: PublishSubject<Element> 
		...
}
Swift
복사

그렇다면, Relay와 Subject의 차이는 뭘까요?

일단, 가장 명확한 차이는 Subject는 RxSwift에서, Relay는 RxCocoa에서 제공해주는 타입입니다.

왜 Relay는 RxCocoa에서 제공해줄까요?

Relay는 Subject와 유사하지만, error, completed 이벤트를 반환하지 않습니다.

즉, 에러가 나도 error 이벤트로 인해 Stream이 종료되지 않기 때문에 UI를 그리는데 적합합니다.

Relay는 disposed 이벤트가 발생하기 전까지 계속 동작합니다.

Subject에서는 next, completed, error 이벤트를 발행했지만, Relay는 completed, error가 없기 때문에 accept()라는 메서드를 사용해서 onNext역할 대신합니다.

Relay의 종류

PublishRelay

PublishSubject를 래핑한 Relay

해당 타입은 PublishSubject의 특성처럼 구독 이후에 발생하는 이벤트들만 알 수 있습니다.

또한, 동일하게 초기값이 없습니다.

let publishRelay = PublishRelay<Int>()
publishRelay.subscribe { print($0) }
publishRelay.accept(5)

/*
next(5)
*/
Swift
복사

BehaviorRelay

BehaviorSubject를 래핑한 Relay

생성 시 하나의 default 값을 저장해야 한다는 점이 BehaviorSubject와 같습니다. 또한, .value를 통해서 마지막 이벤트 값을 가져올 수 있습니다.

let behaviorRelay = BehaviorRelay(value: 5)
behaviorRelay.accept(6)
behaviorRelay.subscribe { print($0) }
behaviorRelay.accept(4)
print(behaviorRelay.value)

/*
next(6)
next(4)
4
*/
Swift
복사