fimuxd/RxSwift를 참고해 정리하는 글입니다 🙂
Subjects
실제 사용하는 방식은 실시간으로 Observable에 수동으로 값을 수동으로 추가하고 subscriber에게 방출
Subjects = Observable + Observer
값을 넘겨주기도 하고 밖에서 주입할 수 있는 양방향성 Observable
- Observable의 값을 외부에서 변경하고 싶을 때
- Observable처럼 값을 받을 수 있고, 밖에서 값을 통제할 수도 있다
- 종류 : PublishSubject, BehaviorSubject, AsyncSubject, ReplaySubject
PublishSubject
let subject = PublishSubject<String>()
subject.onNext("Is anyone listening?")
let subscriptionOne = subject
.subscribe(onNext: { (string) in
print(string)
})
subject.on(.next("1")) //Print: 1
subject.onNext("2") //Print: 2- 데이터가 생기면 데이터를 그대로 방출
.on(.next(_:))새로운.next이벤트를 subject에 삽입 =.onNext(_:)와 동일- 다른 subscriber가 또 subscribe할 수 있음
- subscribe하고 있는 모든 subscriber에게 다 보내줌
- 구독한 이후의 이벤트만 방출
- 따라서 어떤 정보가 추가되었을 때 구독하지 않았다면 그 값을 얻을 수 없음
- 시간에 민감한 데이터를 모델링할 때 사용
.completed또는.error와 같은 종료 이벤트를 받으면 새 subscriber에겐 종료 이벤트를 방출
BehaviorSubjects
- 초기값을 가지고 있음
- 누군가 subscribe하자마자 초기값을 보내줌
- 새로운 subscribe가 되면 변경된 가장 최근 값을 보내줌
let subject = BehaviorSubject(value: "Initial value")
subject.onNext("X")
subject
.subscribe{
print(label: "1)", event: $0)
}
.disposed(by: disposeBag)
subject.onError(MyError.anError)
subject
.subscribe {
print(label: "2)", event: $0)
}
.disposed(by: disposeBag)- 뷰를 가장 최신의 데이터로 미리 채울 때 적합 ex) 데이터를 가져오는 동안 최신 값으로 화면 표시
ReplaySubject
- 한 명의 subscriber만 있을 때는 PublishSubject와 동일
- observer의 subscribe 시점과 관계 없이 모든 데이터를 방출(버퍼 사이즈를 정한 경우 버퍼 크기만큼)
- 버퍼처럼 메모리가 가지고 있기 때문에 이미지나 array 같이 큰 값을 가지는 것은 메모리에 엄청난 부하
let subject = ReplaySubject<String>.create(bufferSize: 2)
subject.onNext("1")
subject.onNext("2")
subject.onNext("3")
subject
.subscribe {
print(label: "1)", event: $0)
}
.disposed(by: disposeBag)
subject
.subscribe {
print(label: "2)", event: $0)
}
.disposed(by: disposeBagerror로 종료해도 버퍼가 살아있어 이후 구독자에게 이벤트를 재방출할 수 있어 바로 dispose를 해줘야 함 → 에러 이벤트만 받게 함- 최근 몇개의 값을 보여주고 싶을 때 사용 ex) 최근 검색어 보여주기
AsyncSubject
- 누가 subscribe 해도 값을 안 보내줌
- completed 되는 시점에 모든 subscriber에게 가장 최근 값을 보내주고 completed
- 가장 마지막 값 = 가장 최신의 값만 필요할 때 사용
iOS Developer