Rx Leak

rxleak.swift

Observable.combineLatest(observable1.asObservable(), observable2.asObservable())
    .subscribe(onNext: { [weak self] (population, state) in
        guard let _self = self else { return }
        switch state {
        case .connectedHost, .connectedParticipant:
            if population == 0 {
                _self.roomPopulationState = .waiting
            } else {
                _self.roomPopulationState = .inARoom
            }
        case .disconnected:
            _self.roomPopulationState = .inNoRoom
        case .connecting:
            _self.roomPopulationState = .joining
        }
})
.disposed(by: disposeBag)