如何使用 RxJava 实现 NullObject 模式答案

【问题标题】：How to achieve NullObject pattern with RxJava如何使用 RxJava 实现 NullObject 模式
【发布时间】：2015-11-10 11:23:02
【问题描述】：

是的，这听起来可能有点雄心勃勃，但这是我想要实现的目标：

我的班级拥有我的热门Observable，班级需要一些时间来正确准备它（在另一个地方创建它并获得参考），所以当另一个班级要求它时，引用可能仍然为空（导致空指针）。我想要实现的目标类似于 NullObject 模式：返回可以安全订阅的空 observable（而不是 null），并且当 Observable 被正确创建时开始发射项目。

解决它的一种方法是创建PublishSubject，它充当客户端类和 ObservableHolder 类之间的桥梁。 PublishSubject 引用总是返回给客户端，当Observable 准备好时，它只会将所有事件转发给主题。这是一个好的解决方案吗？还是可以做得更好？

@edit

我决定继续使用我的解决方案，我认为在课堂上包装它之后，它就已经足够好了。我赞成以下答案，但它与我的问题不匹配，因为它与rx-java 实现没有直接关系，但建议代理模式很有帮助。

【问题讨论】：

PublishSubject 通常是实现此目的的简单方法。如果您想详细了解 observable 是如何准备的，也许我们也可以设计一个无主题的解决方案。
PublishSubject 似乎是合理的。想到的另一种解决方案是让您的可观察准备方法返回Observable<Observable<T>>，但看起来不像带有主题的实现那么干净。

标签： android design-patterns rx-java null-object-pattern

【解决方案1】：

我猜你要找的是proxy pattern。

代理是（顾名思义）一个代替另一个目前不可用的对象的对象。

您可能希望以这种方式使用java.util.Observable 来实现它

public class ObservableProxy extends Observable {


    private ObservableProxyAdapter observableProxyAdapter = new ObservableProxyAdapter();

    private Observable target;

    public void setTarget(Observable target) {
        if(this.target != null){
            // if this proxy was connected to an observer... disconnect
            this.target.deleteObserver(observableProxyAdapter);
        }

        this.target = target;

        if(this.target != null){
            // If a new target is set... connect to it
            this.target.addObserver(observableProxyAdapter);
        }
    }


    private class ObservableProxyAdapter implements Observer {

        public void update(Observable o, Object arg) {
            // forward notifications from the target
            setChanged();
            notifyObservers(arg);

        }

    }

}

您将ObservableProxy 分发给客户。客户可以自己注册到ObservableProxy。稍后当“真正的” Observable 可用时，您可以将其设置为ObservableProxy 的目标。代理将自己注册为Observer 到目标并将通知转发给它的观察者。

+-----------------+  notify  +---------------+   notify   +--------------+
| real observable |  ------> | proxy adapter |   ------>  | observables  |
+-----------------+          +---------------+            |  of proxy    |
                                                          +--------------+

这是一个示例应用程序

public class ObservableProxyTest {

    public static void main(String[] args) {
        ObservableProxy observableProxy = new ObservableProxy();

        Observer someObserver = new Observer() {

            public void update(Observable o, Object arg) {
                System.out.println(arg);
            }
        };
        observableProxy.addObserver(someObserver);


        // Later the real observer becomes available
        RealObservable realProxy = new RealObservable();
        observableProxy.setTarget(realProxy);


        // notifications will be forwarded
        realProxy.notifyHello();
    }

    private static class RealObservable extends Observable {

        public void notifyHello(){
            setChanged();
            super.notifyObservers("Hello World");
        }
    }
}

【讨论】：