RxSwift: Zip Наблюдаемые только если требования будут выполнены

Question

Представьте профиль пользователя, который позволяет редактировать полей как имя, фамилии, возраст и avatarImage. Когда пользователь нажимает Save, запросы отправляются для каждого измененного значения.

Теперь подумайте о функциях с подписями, как те:

func rx_updateUserName(name: String) -> Observable<UpdateUserNameResponse> 
func rx_updateSurname(surname: String) -> Observable<UpdateSurnameResponse> 
func rx_updateAge(age: Int) -> Observable<UpdateAgeResponse> 

Обычно мы просто zip эти запросы, как это:

let nameReqObservable = rx_updateUserName("Gandalf") 
let surnameReqObservable = rx_updateSurname("The White") 
let ageReqObservable = rx_updateAge(123) 

let zippedRequests = Observable.zip(nameReqObservable, surnameReqObservable, ageReqObservable, 
    resultSelector: { (userNameResponse, surnameResponse, areResponse) in 

    return (userNameResponse, surnameResponse, areResponse) 
}).subscribeNext(...) 

Что я должен делать, когда я только хочу, чтобы выполнить запросы для значений, которые изменились?

Answer 1

Вы попробовали .combineLatest()? Визуализация здесь - http://rxmarbles.com/#combineLatest В вашем случае, когда в одном из входных наблюдаемых значений изменяется значение, наблюдаемый combinedRequests будет излучать новый набор входов.

let combinedRequests = Observable.combineLatest(nameReqObservable, surnameReqObservable, ageReqObservable, 
    resultSelector: { (userNameResponse, surnameResponse, ageResponse) in 

    return (userNameResponse, surnameResponse, ageResponse) 
}).subscribeNext(...) 

Док из RxSwift, .combineLatest():

Сливает указанные наблюдаемые последовательности в одной наблюдаемой последовательности с помощью функции селектора всякий раз, когда какой-либо из наблюдаемых последовательностей производит элемент.