如何在RxJava2中链接两个可完成的

Question

我有两个完整的。我想做以下场景：如果第一个Completable到达onComplete，继续第二个Completable。最终结果将是完成第二个可完成项。

这就是我在使用单getUserIdAlreadySavedInDevice（）和Compltable login（）时的做法：

@Override
public Completable loginUserThatIsAlreadySavedInDevice(String password) {
    return getUserIdAlreadySavedInDevice()
            .flatMapCompletable(s -> login(password, s))

}

Answer 1

尝试

Completable.concat

Returns a Completable which completes only when all sources complete, one after another.

http://reactivex.io/RxJava/javadoc/io/reactivex/Completable.html#concat（java.lang.Iterable）

Answer 2

TL；DR：其他答案遗漏了一个微妙之处。使用doThingA（）。然后（doThingB（））如果您想要与concat等效，请使用doThingA（）。然后（可完成。延迟（）-

• flatMap（）是merge（）的映射版本
• 是concat（）的映射版本
• 对于可完成的，您需要使函数调用像单个或可观察的（或者最好是这样，在点击订阅之前什么都不会发生-这是一个很好的惯例，在官方Rx库以及我遇到的任何Rx扩展中都会用到，对于高级用户，这只指冷完成，但大多数人可以忽略这一点）
• 唯一的区别是语法

一些示例：

>

foo（a）. and然后（bar（b））将：

1. 致电foo（a）
2. 即使步骤1返回的completable返回错误，也要立即调用bar（b）
3. 订阅任何返回的步骤
4. 仅当最后一步成功完成时，才会订阅条形图（b）的结果

foo（a）。然后（可完成。延迟（）-

1. 调用foo（a）
2. 订阅步骤1
的结果
3. 只有当foo（a）返回的可完成项成功时，才调用bar（b）

我将省略对merge（）的处理，因为它变得有点复杂，但长话短说，如果你想要“并行”，就可以调用它。

上面的答案有点正确，但我发现它们有误导性，因为它们忽略了渴望评估的微妙之处。

doThingA（）。然后（doThingB（））将立即调用doThingB（），但只有当doThingA（）返回的可观察对象完成时，才订阅doThingB（）html" target="_blank">返回的可观察对象。

doThingA（）。然后（可完成。延迟（）-

只有当doThingB（）在订阅事件之前有副作用时，这才是重要的。例如。Single.just

在subscribe事件之前没有副作用的实现（真正的冷可观察）可能是单一的。仅（1）。doOnSuccess（一）-

在我刚刚遇到的情况下，A是一些验证逻辑，并且立即启动异步数据库更新，从而完成VertX ObservableFuture。这很糟糕。可以说，编写doThingB（）时应该只在订阅时更新数据库，将来我将尝试这样设计。

Answer 3

您正在查找第二个操作员。

返回一个Completable，该Completable首先运行此Completable，然后运行另一个Completable。

firstCompletable
    .andThen(secondCompletable)

通常，此运算符是可完成的平面图的“替换”：

Completable       andThen(CompletableSource next)
<T> Maybe<T>      andThen(MaybeSource<T> next)
<T> Observable<T> andThen(ObservableSource<T> next)
<T> Flowable<T>   andThen(Publisher<T> next)
<T> Single<T>     andThen(SingleSource<T> next)