如何在拋出FlowableOnSubscribe時處理異常？

Flowable.create(new FlowableOnSubscribe<Object>() { 
    @Override 
    public void subscribe(@io.reactivex.annotations.NonNull FlowableEmitter<Object> e) throws Exception { 
    //throws exceptions, how can I handle error it using RxJava 
    }},BackpressureStrategy.LATEST);

取決於情況可能會導致問題，如何處理，我不想使用條件。如何在拋出FlowableOnSubscribe時處理異常？

來源

2017-06-15 A.A.I.A

你是什麼意思？我沒有得到你想要實現的內容 – GVillani82

@ GVillani82由於我寫的代碼，它崩潰並拋出subscribe（）方法中的異常，但是？我想通過使用RxJava錯誤處理來處理它 –

您需要在用戶定義的onError：

.subscribe(new Consumer<String>() { 
        @Override 
        public void accept(@NonNull String o) throws Exception { 
         Log.d("test", o); 
        } 
       }, new Consumer<Throwable>() { 
        @Override 
        public void accept(@NonNull Throwable throwable) throws Exception { 
         Log.e("test", "throwable: " + throwable.getMessage()); 
        } 
       });

然後是Throwable是由用戶來處理。

來源

2017-06-15 23:06:55 GVillani82

如何在拋出FlowableOnSubscribe時處理異常？

回答

相關問題