Обработчик ошибок по умолчанию RxJava

К сожалению, есть возможность установить обработчик ошибок по умолчанию в RxJava?Обработчик ошибок по умолчанию RxJava

Например, я какой-то код в Utils.kt файле:

fun BaseFragment.callGallery(view: View){ 
    view.clicks().bindToLifecycle(this).subscribe { 
     RxPaparazzo.takeImage(this) 
     .usingGallery() 
     .subscribe { response -> 
      throw RuntimeException("Where is this exception from?") 
     } 
    } 
}

Но в StackTrace там нет ни намека о Utils.kt или о какой-либо из моего файла.

Я понимаю, что могу установить onError в каждом подписчике. с кодом:

.subscribe ({ response -> 
    .... 
}, { it.printStackTrace() })

Но я бы предпочел установить один по умолчанию для всех подписчиков. Как мне это сделать?

StackTrace:

05-07 12:11:48.246 10966-10966/ru.egslava.rxfluxtest E/AndroidRuntime: FATAL EXCEPTION: main 
Process: ru.egslava.rxfluxtest, PID: 10966 
java.lang.RuntimeException: Unable to destroy activity {ru.egslava.rxfluxtest/rx_activity_result.HolderActivity}: rx.exceptions.OnErrorNotImplementedException: Where is this exception from? 
    at android.app.ActivityThread.performDestroyActivity(ActivityThread.java:3831) 
    at android.app.ActivityThread.handleDestroyActivity(ActivityThread.java:3849) 
    at android.app.ActivityThread.-wrap5(ActivityThread.java) 
    at android.app.ActivityThread$H.handleMessage(ActivityThread.java:1398) 
    at android.os.Handler.dispatchMessage(Handler.java:102) 
    at android.os.Looper.loop(Looper.java:148) 
    at android.app.ActivityThread.main(ActivityThread.java:5417) 
    at java.lang.reflect.Method.invoke(Native Method) 
    at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:726) 
    at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:616) 
    Caused by: rx.exceptions.OnErrorNotImplementedException: Where is this exception from? 
    at rx.internal.util.InternalObservableUtils$ErrorNotImplementedAction.call(InternalObservableUtils.java:374) 
    at rx.internal.util.InternalObservableUtils$ErrorNotImplementedAction.call(InternalObservableUtils.java:371) 
    at rx.internal.util.ActionSubscriber.onError(ActionSubscriber.java:44) 
    at rx.observers.SafeSubscriber._onError(SafeSubscriber.java:157) 
    at rx.observers.SafeSubscriber.onError(SafeSubscriber.java:120) 
    at rx.exceptions.Exceptions.throwOrReport(Exceptions.java:204) 
    at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:144) 
    at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onNext(OperatorOnErrorResumeNextViaFunction.java:153) 
    at rx.internal.operators.OperatorMap$MapSubscriber.onNext(OperatorMap.java:74) 
    at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:391) 
    at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:353) 
    at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:838) 
    at rx.observers.Subscribers$5.onNext(Subscribers.java:229) 
    at rx.internal.operators.OperatorZip$Zip.tick(OperatorZip.java:264) 
    at rx.internal.operators.OperatorZip$Zip$InnerSubscriber.onNext(OperatorZip.java:335) 
    at rx.internal.operators.OperatorMap$MapSubscriber.onNext(OperatorMap.java:74) 
    at rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:268) 
    at rx.Subscriber.setProducer(Subscriber.java:211) 
    at rx.internal.operators.OperatorMap$MapSubscriber.setProducer(OperatorMap.java:99) 
    at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:79) 
    at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:75) 
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50) 
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
    at rx.Observable.unsafeSubscribe(Observable.java:8452) 
    at rx.internal.operators.OperatorZip$Zip.start(OperatorZip.java:214) 
    at rx.internal.operators.OperatorZip$ZipSubscriber.onNext(OperatorZip.java:156) 
    at rx.internal.operators.OperatorZip$ZipSubscriber.onNext(OperatorZip.java:122) 
    at rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:268) 
    at rx.Subscriber.setProducer(Subscriber.java:209) 
    at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:79) 
    at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:75) 
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50) 
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) 
    at rx.Observable.unsafeSubscribe(Observable.java:8452) 
    at rx.internal.util.ScalarSynchronousObservable$4.call(ScalarSynchronousObservable.java:227) 
    at rx.internal.util.ScalarSynchronousObservable$4.call(ScalarSynchronousObservable.java:220) 
    at rx.Observable.unsafeSubscribe(Observable.java:8452) 
    at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248)

источник

2016-05-07 Slava

Вы можете использовать оператор onErrorResumeNext. Пример использования:

fun BaseFragment.callGallery(view: View){ 
    view 
     .clicks() 
     .bindToLifecycle(this) 
     .onErrorResumeNext { err -> log(err); Observable.empty() } 
     .subscribe { 
     // do stuff 
     } 
}

источник

2016-05-07 11:20:22

RxJava имеет Plugins для поддержки перекрестных проблем режущими красиво. В частности, RxJavaErrorHandler является desiged подключенного поведения обработки глобальной ошибки следующим образом:

RxJavaPlugins.getInstance().registerErrorHandler(object : RxJavaErrorHandler() { 
    override fun handleError(e: Throwable?) { 
     println("Global error handler: $e") 
    } 
}) 

Observable.just(1).concatMap({ Observable.error<Int>(Exception("Just throwing $it")) }) 
     .subscribe({ 
      println("I'll not be called") 
     }, { 
      println("Specific error handler: $it") 
     })

Приведенных выше код будет печатать:

Error occurred java.lang.Exception: Just throwing 1 
A default error handler: java.lang.Exception: Just throwing 1

Я подозреваю, что вы также заинтересованы в улучшении диагностики информации в stacktraces когда у вас есть необработанная ошибка. Для этого существует RxJavaStackTracer, что при использовании RxJavaPlugins.getInstance().registerObservableExecutionHook(RxJavaStackTracer()) улучшает информацию о трассировке стека. Вопрос Stacktraces and subscribeOn/observeOn о github - это хороший прочтение темы.

источник

2016-05-07 12:29:43 miensol

Похоже, что это устарело –

Обработчик ошибок по умолчанию RxJava

ответ

Смежные вопросы