Wie behandelt man die Ausnahme, wenn FlowableOnSubscribe ausgelöst wird?

Question

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); 

Abhängig von der Situation könnte es Probleme verursachen, wie könnte es behandelt werden, möchte ich nicht verwenden, wenn Bedingung.

Answer 1

Sie müssen die onError in Ihrem Teilnehmer definieren:

.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()); 
        } 
       }); 

Und dann wird die throwable vom Teilnehmer behandelt werden.