RxSwift：多次连接到 Connectable Observable答案

【问题标题】：RxSwift: Connect to Connectable Observable multipe timesRxSwift：多次连接到 Connectable Observable
【发布时间】：2017-07-10 13:31:33
【问题描述】：

我在我的 iOS 应用程序中采用了 MVVM 模式。我在我的视图模型中将一系列 Observables 公开为公共属性，并将 UI 绑定到这些属性。这些 Observable 是从私有可连接的 observable 创建的。

然后视图控制器类调用“执行”方法来触发网络请求。但是，如果由于任何原因失败，我希望能够再次调用“执行”，但这不起作用。我相信这是由于可连接的 observable 已经完成。

如何在不必每次都重新创建视图模型的情况下实现这一点？我知道我可以通过使用 flatMap 将简单的执行发布主题转换为 userDetailsObservable 来做到这一点，但我依赖 onCompleted 事件来实现其他功能。由于发布主题保持活动状态，onCompleted 事件将丢失。

可连接的可观察解决方案

class ViewModel {
    public var userName: Observable<String> {
         self.userDetailsObservable.map {
             return $0["username"]
         }
    }

    public var address: Observable<String> {
         self.userDetailsObservable.map {
             return $0["address"]
         }
    }

    public func execute() {
        self.userDetailsObservable.connect()
    }

    private lazy var userDetailsObservable: ConnectableObservable<JSON> {
        return Observable.create { observer in
            // execute network request
            // assume there is a json object and error object returned
            if error != nil {
                observer.onError(error)
            } else {
                observer.onNext(json)
            }
            observer.onCompleted()
        }.publish()
    }
}

FlatMap 解决方案

这将在每次向执行主题推送事件时执行网络请求。 (执行.onNext())。这里的问题是 onCompleted 事件在我们转换发布主题时丢失了。

class ViewModel {
    public var userName: Observable<String> {
         self.userDetailsObservable.map {
             return $0["username"]
         }
    }

    public var address: Observable<String> {
         self.userDetailsObservable.map {
             return $0["address"]
         }
    }

    public var execute: PublishSubject<Void>()

    private lazy var userDetailsObservable: Observable<JSON> {
        return self.execute.flatMapLatest { _ in
            Observable.create { observer in
                // execute network request
                // assume there is a json object and error object returned
                if error != nil {
                    observer.onError(error)
                } else {
                    observer.onNext(json)
                }
                observer.onCompleted()
            }
        }.share()
   }

【问题讨论】：

我认为你可以尝试使用 refcount 而不是 connect

标签： ios swift rx-swift

【解决方案1】：

您应该使用catchError 并返回一个默认值（例如""）。

当您从 API 收到错误时，需要防止 observable 被释放。

【讨论】：