增加异常处理

Author: VeiZhang

AndroidExecLibrary/src/main/java/com/excellence/exec/Command.java

@@ -215,7 +215,17 @@ public void subscribe(ObservableEmitter<String> emitter) throws Exception {
                             mIListener.onSuccess(result.toString());
                         }
                     }
-                }).subscribeOn(Schedulers.io()).subscribe();
+                }).subscribeOn(Schedulers.io()).subscribe(new Consumer<String>() {
+                    @Override
+                    public void accept(String s) throws Exception {
+
+                    }
+                }, new Consumer<Throwable>() {
+                    @Override
+                    public void accept(Throwable throwable) throws Exception {
+                        mIListener.onError(throwable);
+                    }
+                });
             } catch (Exception e) {
                 mIListener.onError(e);
             }