implement invalidationsOf)_

Author: thomasnield

src/main/java/rx/javafx/sources/ObservableValueSource.java

@@ -49,19 +49,11 @@ public static <T> Observable<Change<T>> fromObservableValueChanges(final Observa
         });
     }
 
-    public static <T> Observable<ObservableValue<T>> fromInvalidations(final ObservableValue<T> fxObservable) {
+    public static Observable<javafx.beans.Observable> fromInvalidations(javafx.beans.Observable fxObservable) {
         return Observable.create(subscriber -> {
-            final InvalidationListener listener = s -> subscriber.onNext(fxObservable);
+            final InvalidationListener listener = subscriber::onNext;
             fxObservable.addListener(listener);
             subscriber.add(JavaFxSubscriptions.unsubscribeInEventDispatchThread(() -> fxObservable.removeListener(listener)));
         });
     }
-
-    public static <T> Observable<Property<T>> fromInvalidations(final Property<T> fxProperty) {
-        return Observable.create(subscriber -> {
-            final InvalidationListener listener = s -> subscriber.onNext(fxProperty);
-            fxProperty.addListener(listener);
-            subscriber.add(JavaFxSubscriptions.unsubscribeInEventDispatchThread(() -> fxProperty.removeListener(listener)));
-        });
-    }
 }

src/main/java/rx/observables/JavaFxObservable.java

@@ -121,7 +121,7 @@ public static <T> Observable<Change<T>> fromObservableValueChanges(final Observa
     }
 
     /**
-     * Emits a JavaFX Observable
+     * Emits a JavaFX Observable every time it is invalidated.
      * @param fxObservable
      * @return
      */