java - RxJava 的 Observable.create 与 Observable.just(1).flatMap

Question

我一直在做一些 RxJava，我经常发现自己需要将一些现有代码结果转换为可观察对象。

例如让我们采取以下内容:

ListenableFuture<T> result = request.executeAsync();
return result;

因此，将其转换为可观察对象的最简单方法是执行

ListenableFuture<T> result = request.executeAsync();
return Observable.from(result);

问题是 executeAsync 在调用时实际执行请求。我想要的是延迟该调用，直到订阅了可观察对象。

我想到了两种方法

return Observable.create { aSubscriber ->
    if (!aSubscriber.unsubscribed) {
        aSubscriber.onNext(request.executeAsync())
    }
    if (!aSubscriber.unsubscribed) {
        aSubscriber.onCompleted()
    }
}

和

return Observable
    .just(1)
    .flatMap((_) -> Observable.from(request.executeAsync()));

在我看来，使用 flatMap 选项更简单，因为我不必为订阅者逻辑操心。

在 create 上使用 flatMap 有什么陷阱吗？是否有首选的 Rx 方式来简化集成？

谢谢

Answer 1

您可以改用 defer :

Observable.defer(() -> request.executeAsync())
          .concatMap(Observable::from)
          .subscribe();