Implement WindowEvents

Author: thomasnield

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

@@ -0,0 +1,30 @@
+package rx.javafx.sources;
+
+import javafx.event.EventHandler;
+import javafx.event.EventType;
+import javafx.stage.Window;
+import javafx.stage.WindowEvent;
+import rx.Observable;
+import rx.Subscriber;
+import rx.schedulers.JavaFxScheduler;
+import rx.subscriptions.JavaFxSubscriptions;
+
+public final class WindowEventSource {
+
+    private WindowEventSource() {}
+
+    public static <T extends WindowEvent> Observable<T> fromWindowEvents(final Window source, final EventType<T> eventType) {
+
+        return Observable.create(new Observable.OnSubscribe<T>() {
+            @Override
+            public void call(final Subscriber<? super T> subscriber) {
+                final EventHandler<T> handler = subscriber::onNext;
+
+                source.addEventHandler(eventType, handler);
+
+                subscriber.add(JavaFxSubscriptions.unsubscribeInEventDispatchThread(() -> source.removeEventHandler(eventType, handler)));
+            }
+
+        }).subscribeOn(JavaFxScheduler.getInstance());
+    }
+}

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

@@ -77,6 +77,17 @@ public static <T extends Event> Observable<T> fromSceneEvents(final Scene scene,
         return SceneEventSource.fromSceneEvents(scene,eventType);
     }
 
+    /**
+     * Creates an observable corresponding to javafx Window events.
+     *
+     * @param window      The target of the UI events.
+     * @param eventType The type of the observed UI events
+     * @return An Observable of UI events, appropriately typed
+     */
+    public static <T extends WindowEvent> Observable<T> fromWindowEvents(final Window window, final EventType<T> eventType) {
+        return WindowEventSource.fromWindowEvents(window,eventType);
+    }
+
     /**
      * Creates an observable corresponding to javafx Node action events.
      *