java - RxJava : Connect observers?

Question

是否有 RxJava 方式连接到观察者？

我的意思是，而不是:

Observer<Object> observer1 = new Observer<Object>() { // ... }
Observer<Object> observer2 = new Observer<Object>() {
    @Override
    public void onNext(Object event) {
        observer1.onNext(event);
    }
    // ...
    };

以便观察者链接在一起(当调用原始 onNext() 时，调用辅助 onNext() )。

Answer 1

我建议您使用处理器，它既是可观察的又是观察者。

在您的示例中:

//Your observable
Observable observable = Observable.just(...);

Observer<Object> observer1 = new Observer<Object>() { // ... }

PublishSubject<Object> observer2 = PublishSubject.create();
// observer1 will receive all onNext and onCompleted events
observer2.subscribe(observer1);

//observer2 will get items from observable and propagate them to observer1
observable.subscribe(observer2);