RxJava、副作用和返回void的方法

Question

我已经使用RxJava编写了一个存储库，但在找到处理对repo的写入和删除的最佳方法时遇到了麻烦。

repository
    .fetchData()
    .doOnNext(s -> if (s.equals("something") {
                       repository.writeData(s);
                   }
    )
    .subscribe();

我找到了2个潜在的解决方案，但不确定它们的正确程度：

1）使用observable.just（null)启动一个observable，然后使用doonnext()副作用方法调用存储库的方法。这是可行的，看起来很奇怪，但它允许我使用RxJava，并允许我指定要订阅的线程/要观察的线程，这使得线程处理变得容易，并且允许存储库的API保持不变，这样它仍然返回void。

2）我还可以做一些类似Observable.defer()的事情，然后从defer的调用方法返回Observable.just(repository.deleteData())。如果我这样做，我必须更改存储库的API，以便deleteData方法具有Void返回类型而不是Void（并且该方法添加了return null；来履行方法签名的约定）。这也允许我使用RxJava，指定我要观察和订阅的线程，并继续使用Observable即使我真正做的是一个副作用。

RxJava有没有办法创建一个Observable，它调用一个返回类型为void的方法，该方法在副作用方法之外运行同步代码？

Answer 1

为什么不是这样的呢？

public static <T> Observable<T> observeCompletion(Runnable r) {
   return Observable.defer(() -> {
         r.run();
         return Observable.empty();
   };
}

现在，您可以通过onSubscribe执行所需的线程跳转，并将所有内容保存在RX中。