如何知道在下游订阅服务器上何时调用onNext（）？

Question

所以我有一个可观察的。我想知道每个下游订户onnext调用何时发出，这既是为了测量每个下游订户花费的时间，也是为了反压。

observable.lift让我半途而废--我可以用自己的订阅服务器包装每个单独的订阅服务器，如下面的示例所示。当所有下游订户完成下一个调用时，它不会通知我，而我自己也不必做一些记账。

eventObservable.lift(subscriber -> new Subscriber<Event>() {
        @Override
        public void onStart() {
            request(1);
        }

        @Override
        public void onCompleted() {
            subscriber.onCompleted();
        }

        @Override
        public void onError(Throwable e) {
            subscriber.onError(e);
        }

        @Override
        public void onNext(Event event) {
            subscriber.onNext(event);
            request(1);
        }
    });

提前感谢！

Answer 1

像doOnXXX这样的doOnXXX方法http://reactivex.io/rxjava/javadoc/rx/observable.html#doOnNext%28rx.functions.action1%29对您来说足够吗？这样您就可以截获onNext和其他事件。