java - 我如何创建订阅可观察对象的 BehaviorSubject？

Question

我有一个函数应该返回一个BehaviorSubject。该主题旨在返回 Profile

的最新版本

(user)Profile 只是一个包含对三个成员的引用的 POJO:
- 用户,
- 该用户的 MeasurementList,
- 和一个截止日期。

其中两个属性是通过改造调用获得的，其中一个已经保存在类变量中。

每当 observable 发出一个新的measurement list 或 deadline 时，BehaviorSubject 应该发出一个新的更新的 Profile。

这是应该发生什么的(希望有用的)图表

这是我目前的情况

 public BehaviorSubject<Profile> observeProfile() {

        if (profileBS == null) {

            profileBS = BehaviorSubject.create();

            Observable o = Observable.combineLatest(
                    Observable.just(userAccount),
                    observeMeasurements(),
                    observeDeadline(),
                    Profile::new
            );


            profileBS.subscribeTo(o); //subscribeTo does not exist, but this is what I am trying to figure out how to do.

        }
        return profileBS;
    }

谁能帮我正确地创建这个 BehaviorSubject？

谢谢。

Answer 1

Subject 实现了 Observer 接口(interface)，因此您可以执行以下操作

public BehaviorSubject<Profile> observeProfile() {

        if (profileBS == null) {

            profileBS = BehaviorSubject.create();

            Observable o = Observable.combineLatest(
                    Observable.just(userAccount),
                    observeMeasurements(),
                    observeDeadline(),
                    Profile::new
            );

            // Note the following returns a subscription. If you want to prevent leaks you need some way of unsubscribing.
            o.subscribe(profileBS); 

        }
        return profileBS;
}

请注意，您应该想出一种方法来处理生成的订阅。