Merge pull request #596 from sialcasa/595_fix_running_property_in_syn…

…c_mode

#595 Fix runningProperty for DelegateCommand in sync mode

mvvmfx/src/main/java/de/saxsys/mvvmfx/utils/commands/DelegateCommand.java

@@ -142,6 +142,14 @@ public void execute() {
 	private ObjectProperty<State> getStateObjectPropertyReadable() {
 		return (ObjectProperty<State>) stateProperty();
 	}
+
+	/**
+	 * In synchronous mode we need to simulate the lifecycle of the service and therefore manipulate the
+	 * {@link Service#runningProperty()}.
+	 */
+	private BooleanProperty getRunningPropertyReadable() {
+		return (BooleanProperty) runningProperty();
+	}
 
 	protected void callActionAndSynthesizeServiceRun() {
 		try {
@@ -153,8 +161,11 @@ protected void callActionAndSynthesizeServiceRun() {
 			Action action = actionSupplier.get();
 			setWritableExceptionProperty(action);
 			bindServiceExceptionToTaskException();
-
+
+			getRunningPropertyReadable().set(true);
 			action.action();
+			getRunningPropertyReadable().set(false);
+
 			getStateObjectPropertyReadable().setValue(State.SUCCEEDED);
 		} catch (Exception e) {
 			setException(e);

mvvmfx/src/test/java/de/saxsys/mvvmfx/utils/commands/DelegateCommandTest.java

@@ -23,6 +23,7 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 import java.util.function.BiConsumer;
 import java.util.function.Supplier;
@@ -415,4 +416,34 @@ private void sleep(long millis) {
 			e.printStackTrace();
 		}
 	}
+
+
+	@Test
+	void testRunningPropertyForSynchronousMode() {
+		CountDownLatch commandExecutedLatch = new CountDownLatch(1);
+		CountDownLatch listenerCalledLatch = new CountDownLatch(1);
+
+		Command command = new DelegateCommand(() -> new Action() {
+			@Override
+			protected void action() throws Exception {
+				commandExecutedLatch.countDown();
+			}
+		});
+
+		command.runningProperty().addListener((observable, oldValue, newValue) -> {
+			listenerCalledLatch.countDown();
+		});
+
+		// when
+		command.execute();
+
+		// then
+		Assertions.assertDoesNotThrow(() -> {
+			commandExecutedLatch.await(2, TimeUnit.SECONDS);
+			listenerCalledLatch.await(2, TimeUnit.SECONDS);
+		});
+
+		Assertions.assertEquals(0, commandExecutedLatch.getCount(), "Action was not executed");
+		Assertions.assertEquals(0, listenerCalledLatch.getCount(), "Listener was not invoked");
+	}
 }