java - 如何实现BehaviorSubject + retrofit api调用

Question

我是 RxJava 的新手。

我对 api 调用 api.java 使用改造:

@GET("someurl")
Observable<Profile> getProfile(); 

我想用一个返回 Observable<Profile> 的方法实现一些服务和:

1) 如果有人首先订阅了 observable，那么在开始时调用 API 请求并且结果(配置文件)将在订阅者处可用。

2) 如果其他人订阅了 observable，则订阅者无需调用 API 即可获得已缓存的数据(来自第一个订阅者)。对于第 3、4 个订阅者也是如此......

3) 一些新订阅者希望通过 API 调用获取“最后”数据。在这种情况下，将调用 API 请求，所有订阅者都将获得最后的数据。

我的解决方案MyService.java:

private final BehaviorSubject<Profile> profile = BehaviorSubject.create();

public BehaviorSubject<Profile> subscribe(boolean useCache) {
        if (!useCache || !profile.hasValue()) {
            api.getProfile().subscribe(new Consumer<Profile>() {

                @Override
                public void accept(UserProfile result) throws Exception {
                    profile.onNext(result);
                }
            });
        }

        return profile;
    }

但是这个解决方案看起来很麻烦。此外，调用 API 后无法取消订阅。

Answer 1

让您的主题订阅您实际的 API 可观察对象，然后其他订阅者改为订阅该主题。

Api api = getRetrofitApiInterfaceIpml();
BehaviorSubject<Profile> subject = BehaviorSubject.create();
Observable<Profile> profileObservable = api.getProfile();
profileObservable.subscribe(subject);

然后将 Subject 公开为可观察的以供订阅。