我可以用可完成的方式将平面映射到其他流吗？

Question

我有几个completable rx subscriptions 在这样的流中：

viewModel?.setupDoorMode().subscribe(onNext: { shouldConnectToDoor in
    if shouldConnectToDoor {
         self.viewModel?.connectAndOpenDoor().subscribe(onCompleted: {
             self.viewModel?.openOrCloseDoor().subscribe().disposed(by: self.disposeBag)
         }).disposed(by: self.disposeBag)
    } else {
         self.viewModel?.openOrCloseDoor().subscribe().disposed(by: self.disposeBag)
    }
}).disposed(by: disposeBag)

我觉得这可以用更好的方式完成，比如将流平面映射到另一个流中。但是当我尝试使用flatMap 时，我得到了错误Type '()' cannot conform to 'ObservableConvertibleType'; only struct/enum/class types can conform to protocols。我对rx 不太熟悉，无法理解该消息。无论如何，有没有办法创建一个看起来更流畅的流而不是连续三个subscriptions？

Answer 1

您在考虑 flatMap 来编写您的 observable 时肯定走在正确的轨道上。这里要注意的是，调用.subscribe() 会返回一个Disposable 类型，并在该一次性返回Void 又名() 类型上调用.disposed(by:)。你不能写Voids。您已经编写了 observables，然后您订阅了结果。

guard let viewModel = viewModel else { return }

// Combine the observables
let doorActionObservable = viewModel
    .setupDoorMode()
    .flatMap { /* mind the retain cycle */ shouldConnectToDoor in
        if shouldConnectToDoor {
            return self.viewModel.connectAndOpenDoor()
        } else {
            return self.viewModel.openOrCloseDoor()
        }
    }

// Subscribe to the the resulting observable
doorActionObservable
    .subscribe()
    .disposed(by: disposeBag)