RxSwift - How to handle different error scenarios with Observable.zip

user_2407557 0
Viewed 867

I have this code:

    ...
    let minMaxReq = networkProvider.getMinMaxAmortization(id: id)
    let emitExtractReq = networkProvider.getEmitExtract(id: id)

    self.isLoading.accept(true)

    Observable.zip(minMaxReq.asObservable(), emitExtractReq.asObservable()) { (minMaxResp, emitExtractResp) in
            return (minMaxResp, emitExtractResp)
        }.subscribe(onNext: { [weak self] responses in

            let minMaxResp = responses.0
            let emitExtractResp = responses.1

            guard let self = self else { return }

            self.isLoading.accept(false)
            self.getMinMaxAmortizationResponse.accept(minMaxResp)
            self.receiptsCNH.accept(emitExtractResp)

        }, onError: { [weak self] error in

            self?.isLoading.accept(false)
            self?.receivedError.accept(error)

        }).disposed(by: disposeBag)

In this case all errors from both requests will end up in the onError closure, how can I handle the error from minMaxReq in a different onError closure?

My goal is to make the 2 requests at the same time but handle their error with different closures. How can I achieve this? thanks

observable swift zip ios
1 Answers

Have you tried the materialize operator? Maybe it can be useful for the implementation you need. Annex an example of how it is usually used:

let valid = network.getToken(apikey)
            .flatMap{ token in self.verifyToken(token).materialize()}
            .share()

valid
    .compactMap { $0.element }
    .subscribe(onNext: { data in print("token is valid:", data) })
    .disposed(by: disposeBag)

valid
    .compactMap { $0.error?.localizedDescription }
    .subscribe(onNext: { data in print("token is not valid:", data) })
    .disposed(by: disposeBag)

In that way, you could divide the stream into two and give it the appropriate treatment.

Another option might be to manipulate the error event in the minMaxReq operation. Something similar to:

let minMaxReq = networkProvider.getMinMaxAmortization(id: id)
                        .catchError({ error in Observable.empty()
                        .do(onCompleted: { /* Do anything with no side effect*/  }) })

let emitExtractReq = networkProvider.getEmitExtract(id: id)

Observable.zip(...)

Here is an article that explains more detail Handling Errors in RxSwift

user_32327780
Related