RxSwift: 链 Completable 到 Observable答案

【问题标题】：RxSwift: Chain Completable to ObservableRxSwift: 链 Completable 到 Observable
【发布时间】：2018-06-08 05:25:24
【问题描述】：

我想将 Completable 链接到可观察元素。调用 flatMap 后，onCompleted 和 onError 回调似乎不会在订阅时调用。

var user = PublishRelay<User>()

func fetchUserInformation(_ userId: String) -> Completable {
    return Completable.create { observer in
        apiService.fetchInformation(for: userId, completion: { response in
            if let name = response?.name {
                user.accept(User(name: name))
                observer(.completed)
            } else {
                observer(.error(ServiceError.userInformation))
            }
        })
        return Disposables.create()
    }
}

login()
.flatMap{ userId in fetchUserInformation(userId) }
.subscribe(
    onCompleted: {
        print("Success!") // Not being called at all
    },
    onError: { error in
        print(error)  // Not being called at all
    }
).disposed(by: disposeBag)

虽然 fetchUserInformation 和 observer(.completed) 被调用并且用户信息被成功获取，但我无法捕捉到 onCompleted em> 订阅时（仅当前面有 flatMap 时）。

有没有一种干净的方法来实现这一点？

已经在 flatMap 调用之后尝试了 .materialized() 以获得
    Observable<Event<Never>>
而不是一个
    Observable<Never>
它也不起作用。

【问题讨论】：

如果 Completable 不符合您的需求，请不要使用...此外，不会调用 onCompleted，因为当您的内部可观察 (fetchUserInformation) 完成时，这并没有完成您的外部可观察对象：在下一次登录值时，它将再次触发fetchUserInformation。

标签： ios swift observable rx-swift

【解决方案1】：

正确的解决方案是使用“andThen”运算符。

someCompletable
   .andThen(someObservable)

编辑：只需阅读您的其余代码 - 我不确定您为什么要使用 Completable，因为您似乎实际上是从该流中返回了一些元素。

您可能希望使用Single 或Plain-ol' observable 来中继该值，而无需使用外部中继。

【讨论】：

很高兴知道 -1 的用途 :)

【解决方案2】：

我认为你可以这样做：

login()
    .flatMap{ userId -> Observable<Void> in
        return fetchUserInformation(userId).andThen(.just(Void()))
    }.subscribe(onNext: { _ in
        ...
    }).disposed(by: disposeBag)

【讨论】：

【解决方案3】：

据我所知，您无法将 Completable 转换为 Observable，因为后者会省略值，而 Completable 不会。

我猜 flatMap 正在从 Login 返回 Observables，然后您将其转换为 Completables，这就是它失败的原因

【讨论】：