Fixed Bug for AbstractStageTest

src/main/java/teetime/framework/AbstractStage.java

@@ -317,6 +317,7 @@ public abstract class AbstractStage {
 					sendTerminatingSignal = true;
 				}
 			} else {
+				if (inputPortsWithPreTerminatingSignals != null) {
 					inputPortsWithSignals.addAll(inputPortsWithPreTerminatingSignals);
 					if (signal.mayBeTriggered(inputPortsWithSignals, getInputPorts())) { // min one Terminating or
 																							// PreTerminating on each
@@ -329,8 +330,7 @@ public abstract class AbstractStage {
 						}
 						receivedPreTerminatingSignals = Collections.emptySet();
 					}
-
-				else { // not every InputPort received any signal jet
+				} else { // not every InputPort received any signal jet
 					if (!sendPreTerminatingSignal) {
 						for (OutputPort<?> outputPort : outputPorts.getOpenedPorts()) {
 							outputPort.sendSignal(new PreTerminatingSignal(this.id));
@@ -380,6 +380,7 @@ public abstract class AbstractStage {
 					sendTerminatingSignal = true;
 				}
 			} else {
+				if (inputPortsWithPreTerminatingSignals != null) {
 					receivedPreAndTerminationSignals.addAll(inputPortsWithPreTerminatingSignals);
 					if (signal.mayBeTriggered(receivedPreAndTerminationSignals, getInputPorts())) { // min one Terminating or
 																									// PreTerminating on each InputPort
@@ -390,6 +391,7 @@ public abstract class AbstractStage {
 						}
 						receivedPreTerminatingSignals = Collections.emptySet();
 
+					}
 				} else { // not every InputPort received any signal jet
 					if (!sendPreTerminatingSignal) {
 						for (OutputPort<?> outputPort : outputPorts.getOpenedPorts()) {