RxSwift 종속성

RxSwift를 사용해 본 적이 있다면 다음 코드 스니펫에 익숙할 것입니다.

var taskChangeEvent = BehaviorSubject<Bool>()
...

if newValue != oldValue {
  subject.onNext(newValue)
}

...

taskChangeEvent.subscribe(onNext: { [weak self] done in
    ....
}).dispose(by: disposeBag)

이 프로세스를 좀 더 간단하게 만들고 단일 위치에 대한 RxSwift 종속성을 줄이기 위해 이 단계를 수행하는 간단한 클래스를 빌드합니다.

import RxSwift

class EventSerializer<T: Equatable> {
    private var disposeBag = DisposeBag()
    fileprivate let contactPoint: BehaviorSubject<T>
    var value: T

    func send(_ newValue: T) {
        contactPoint.onNext(newValue)
        self.value = newValue
    }
    func sendValueIf(_ newValue: T, compareWith: (_ oldValue: T, _ newValue: T) -> Bool) {
        if compareWith(self.value, newValue) {
            contactPoint.onNext(newValue)
            self.value = newValue
        }
    }
    func listen(onChange: @escaping ((T) -> Void)) {
        contactPoint.subscribe( onNext: { value in
            onChange(value)
        }).disposed(by: disposeBag)
    }
    init(defaultValue: T, contactPoint: BehaviorSubject<T>? = nil) {
        self.contactPoint = contactPoint ?? BehaviorSubject<T>(value: defaultValue)
        self.value = defaultValue
    }
}

발사 로직은 클래스 내부에 있으며 로직을 별도의 함수로 나눌 수 있습니다.

스트림을 듣는 것이 훨씬 깨끗하고 코드 전체에 disposeBag가 없습니다.

var task = EventSerilizer<Bool>(defaultValue: false)

...

func shouldInformTaskChange(_ oldValue: Bool, _ newValue: Bool) {
    oldValue != newValue
}
task.sendValueIf(true, compareWith: shouldInforTaskChange)

...

task.listen { [weak self] value in 
    ....
}

func listenToCombineLatest<E: Equatable>(with otherSerializer: EventSerializer<E>, onChange: @escaping ((T, E) -> Void)) {
    Observable.combineLatest(self.contactPoint, otherSerializer.contactPoint).subscribe(onNext: { tValue, eValue in
        onChange(tValue, eValue)
    }).disposed(by: disposeBag)
}

BehaviorSubject 사용에 대한 참고 사항

아시다시피 BehaviorSubject는 듣기 시작하는 마지막 이벤트를 발행합니다. 이것은 파이프에 물이 있을 때 배관과 같기 때문에 설정 단계에서 문제가 될 수 있습니다. 아직 준비되지 않은 상태에서 방문하게 됩니다. 반면에 PublishSubject를 사용하면 파이프를 함께 연결한 다음 이벤트를 보낼 수 있습니다.

따라서 이벤트를 수신하기 전에 약간의 준비 시간이 필요한 경우 PublishSubject 사용을 고려하십시오.