Merge pull request #82 from jschneider/error-handler

do not ignore exceptions, call RxJavaPlugins.onError instead

Author: thomasnield

src/main/java/io/reactivex/rxjavafx/observers/JavaFxObserver.java

@@ -15,15 +15,16 @@
  */
 package io.reactivex.rxjavafx.observers;
 
+import java.util.Optional;
+
 import io.reactivex.Observable;
 import io.reactivex.functions.Consumer;
 import io.reactivex.observables.ConnectableObservable;
+import io.reactivex.plugins.RxJavaPlugins;
 import io.reactivex.rxjavafx.observables.JavaFxObservable;
 import javafx.beans.binding.Binding;
 import javafx.beans.value.ObservableValue;
 
-import java.util.Optional;
-
 public enum JavaFxObserver {
     ;//no instances
 
@@ -141,6 +142,6 @@ public static <T> Binding<T> toLazyNullableBinding(Observable<Optional<T>> obs,
     }
 
     private static void onError(Throwable t) {
-        // nothing
+        RxJavaPlugins.onError(t);
     }
 }

src/main/java/io/reactivex/rxjavafx/observers/JavaFxSubscriber.java

@@ -18,6 +18,7 @@
 import io.reactivex.Flowable;
 import io.reactivex.flowables.ConnectableFlowable;
 import io.reactivex.functions.Consumer;
+import io.reactivex.plugins.RxJavaPlugins;
 import io.reactivex.rxjavafx.observables.JavaFxObservable;
 import javafx.beans.binding.Binding;
 import javafx.beans.value.ObservableValue;
@@ -141,6 +142,6 @@ public static <T> Binding<T> toLazyNullableBinding(Flowable<Optional<T>> flowabl
     }
 
     private static void onError(Throwable t) {
-        // nothing
+        RxJavaPlugins.onError(t);
     }
 }