FlowableOnSubscribeがスローされたときに例外を処理する方法は？

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

状況によっては問題が発生する可能性がありますが、どうすれば処理できるのでしょうか、条件がある場合は使いたくありません。

Answer 1

あなたは、あなたの加入者での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()); 
        } 
       }); 

そしてスロー可能オブジェクトは、加入者によって処理されます。