start invalidation factories

Author: thomasnield

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

@@ -15,10 +15,11 @@
  */
 package rx.javafx.sources;
 
+import javafx.beans.InvalidationListener;
+import javafx.beans.property.Property;
 import javafx.beans.value.ChangeListener;
 import javafx.beans.value.ObservableValue;
 import rx.Observable;
-import rx.Subscriber;
 import rx.subscriptions.JavaFxSubscriptions;
 
 public class ObservableValueSource {
@@ -48,4 +49,19 @@ public static <T> Observable<Change<T>> fromObservableValueChanges(final Observa
         });
     }
 
+    public static <T> Observable<ObservableValue<T>> fromInvalidations(final ObservableValue<T> fxObservable) {
+        return Observable.create(subscriber -> {
+            final InvalidationListener listener = s -> subscriber.onNext(fxObservable);
+            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

@@ -120,6 +120,15 @@ public static <T> Observable<Change<T>> fromObservableValueChanges(final Observa
         return changesOf(fxObservable);
     }
 
+    /**
+     * Emits a JavaFX Observable
+     * @param fxObservable
+     * @return
+     */
+    public static Observable<javafx.beans.Observable> invalidationsOf(final javafx.beans.Observable fxObservable) {
+        return ObservableValueSource.fromInvalidations(fxObservable);
+    }
+
     /**
      * Creates an observable corresponding to javafx Scene events.
      *