RxJava debug

gistfile1.java

  RxJavaPlugins.getInstance().registerObservableExecutionHook(new DebugHook(new DebugNotificationListener() {
                public Object onNext(DebugNotification n) {
                    Timber.v("onNext on " + n);
                    return super.onNext(n);
                }

                public Object start(DebugNotification n) {
                    Timber.v("start on " + n);
                    return super.start(n);
                }

                public void complete(Object context) {
                    super.complete(context);
                    Timber.v("onNext on " + context);
                }

                public void error(Object context, Throwable e) {
                    super.error(context, e);
                    Timber.v("error on " + context);
                }
            }));