rx-java - 将 Observable 映射到 Observable

Question

我要执行 task 1然后 task 2无需组合他们发出的元素。我有这个:

interface Service {
    Observable<Something> doTask1();
    Observable<SomethingElse> doTask2();
}

这是让他们返回的好方法吗 Observable<Void>为了合并它们？这两个任务都是独立的，所以第一个可能会返回一个空的 Observable。但是无论如何都必须执行第二个。

public Observable<Void> doTasks() {
    Observable.merge(service.doTask1(), service.doTask2());
}

如果是这样，是否有任何“正确”的方式来映射 Observable<Something>至 Observable<Void> ？我是这样做的:

public class TaskService implements Service {
    public Observable<Void> doTask1() {
        return getSomething().map(new Func1<Something, Void>() {
                    @Override
                    public Void call(Something something) {
                        return null;
                    }
                });
    } 
}

任何建议将不胜感激。

Answer 1

将值映射到 Void 是一种有效的方式，但是，RxJava 引入了 Completable，它是 Observable 的变体，它不会发出项目，而只是完成和错误通知.您可以在这里使用它，因为您不关心发出的值，然后您将获得更清晰的 API，并且不需要将值映射为更少的值。

public Completable doTasks() {    
    Completable.merge(service.doTask1().toCompletable(), service.doTask2().toCompletable());
}