dector
Observable.subscribe(final Action1<? super T> onNext) {
@Override public final void onError(Throwable e) { throw new OnErrorNotImplementedException(e); }