diff --git a/src/main/java/teetime/stage/basic/merger/Merger.java b/src/main/java/teetime/stage/basic/merger/Merger.java index d8b0320a7fbe6f12093fa1a80cdfa76fc6007761..adeb4abbd0ee85aa343726b28b25fd7cf6e6cda3 100644 --- a/src/main/java/teetime/stage/basic/merger/Merger.java +++ b/src/main/java/teetime/stage/basic/merger/Merger.java @@ -24,6 +24,7 @@ import teetime.framework.AbstractStage; import teetime.framework.InputPort; import teetime.framework.OutputPort; import teetime.framework.signal.ISignal; +import teetime.framework.signal.StartingSignal; /** * @@ -94,7 +95,7 @@ public final class Merger<T> extends AbstractStage { signalMap.put((Class<ISignal>) signalClass, tempSet); } - if (signalMap.get(signalClass).size() == this.getInputPorts().length) { + if (signalMap.get(signalClass).size() == this.getInputPorts().length || signalClass == StartingSignal.class) { signal.trigger(this); this.outputPort.sendSignal(signal); signalMap.remove(signalClass); diff --git a/src/site/markdown/wiki b/src/site/markdown/wiki index 0e4474577e1f49bc96e734c286b2d9e0363895e8..63ccbbc87bd2c0e6599ca91502149dba3cfb99de 160000 --- a/src/site/markdown/wiki +++ b/src/site/markdown/wiki @@ -1 +1 @@ -Subproject commit 0e4474577e1f49bc96e734c286b2d9e0363895e8 +Subproject commit 63ccbbc87bd2c0e6599ca91502149dba3cfb99de