ios - 防止处置PublishSubject(RxSwift)

我正在努力结合RxSwift的PublishSubject的特定用例。

为了简单起见，省略了无关紧要的细节。

有MVVM设置。在VC中，我有一个UIButton，应在其上分派网络调用。在ViewModel中，我有一个buttonDidTapSubject: PublishSubject<Void>。

class ViewModel {
  let disposeBag = DisposeBag()
  let buttonDidTapSubject = PublishSubject<Void>()
  let service: Service
  typealias Credentials = (String, String)
  var credentials: Observable<Credentials> {
   return Observable.just(("testEmail", "testPassword"))
  }
  init(_ service: Service) {
   self.service = service
   buttonDidTapSubject
    .withLatestFrom(credentials)
    .flatMap(service.login) // login method has signature func login(_ creds: Credentials) -> Observable<User>
    .subscribe(onNext: { user in print("Logged in \(user)") },
               onError: { error in print("Received error") })
    .disposed(by: disposeBag)
  }
}

class ViewController: UIViewController {
  let viewModel: ViewModel
  let button = UIButton()
  init(_ viewModel: ViewModel) {
    self.viewModel = viewModel
  }
}

在控制器的viewDidLoad中，我进行了绑定:

override func viewDidLoad() {
  button.rx.tap.asObservable()
    .subscribe(viewModel.buttonDidTapSubject)
    .disposed(by: disposeBag)
}

问题是，由于网络请求可能失败，并且从login(_:)方法返回的Observable会产生错误，因此将丢弃ViewModel中对buttonDidTapSubject的整个预订。按钮上的所有其他轻击都不会触发序列登录ViewModel。

有什么办法可以避免这种行为？

最佳答案

您可以使用retry防止完成订阅。如果您只想在特定情况下或错误中重试，则也可以使用retryWhen运算符

在视图模型中:

lazy var retrySubject: Observable<Void> = {
    return viewModel.buttonDidTapSubject
            .retryWhen { error in
                if (error == .networkError){ //check here your error
                    return .just(Void())
                } else {
                    return .never() // Do not retry
                }
            }
}()

在视图控制器中，我会以另一种方式完成它:

override func viewDidLoad() {
  super.viewDidLoad()
  button.rx.tap.asObservable()
    .flatMap { [weak self] _ in
      return self?.viewModel.retrySubject
    }
    .subscribe(onNext: {
        //do whatever
    })
    .disposed(by: disposeBag)
  }

关于ios - 防止处置PublishSubject(RxSwift)，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/50584324/