我一直在做一些 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 方式来简化集成?
谢谢
最佳答案
您可以改用 defer :
Observable.defer(() -> request.executeAsync())
.concatMap(Observable::from)
.subscribe();
关于java - RxJava 的 Observable.create 与 Observable.just(1).flatMap,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31008098/