Test for scene event

shadskii · Nov 6, 2017 · 6b971ff · 6b971ff
1 parent 6e6b9f9
commit 6b971ff
Showing 1 changed file with 28 additions and 1 deletion.
diff --git a/fxcellent-reactor/src/test/java/freetimelabs/fxcellent/reactor/flux/FxFluxFromTest.java b/fxcellent-reactor/src/test/java/freetimelabs/fxcellent/reactor/flux/FxFluxFromTest.java
@@ -107,7 +107,7 @@ public void testObservable()
     {
         SimpleBooleanProperty observable = new SimpleBooleanProperty(false);
         AtomicBoolean actual = new AtomicBoolean();
-        FxFluxFrom.oberservable(observable)
+        FxFluxFrom.observable(observable)
                   .publishOn(thread)
                   .subscribe(actual::set);
         observable.set(true);
@@ -132,6 +132,33 @@ public void testObservableList()
         assertThat(actual.get()).containsExactly(1, 2, 3);
     }
 
+    @Test
+    public void testSceneEvent() throws TimeoutException, InterruptedException
+    {
+        AtomicReference<Scene> actual = new AtomicReference<>();
+        AtomicReference<Node> actualNode = new AtomicReference<>();
+        setStage(stage ->
+        {
+            Pane pane = new Pane();
+            Scene scene = new Scene(pane);
+            actualNode.set(pane);
+            actual.set(scene);
+            stage.setScene(scene);
+        });
+
+        AtomicReference<Event> event = new AtomicReference<>();
+        Scene scene = actual.get();
+
+        FxFluxFrom.sceneEvent(scene, KeyEvent.KEY_TYPED)
+                  .publishOn(thread)
+                  .subscribe(event::set);
+
+
+        actualNode.get()
+                  .fireEvent(new KeyEvent(KeyEvent.KEY_TYPED, "", "", KeyCode.CODE_INPUT, false, false, false, false));
+        assertThat(event.get()
+                        .getSource()).isEqualTo(scene);
+    }
 
     public static final class TestApp extends Application
     {