diff --git a/src/main/java/teetime/stage/basic/merger/Merger.java b/src/main/java/teetime/stage/basic/merger/Merger.java index 06be1614888f17735a0998ba5821e64b51187b3c..48100e5c187408fd931d7f5fe7d78ffad97ec0bd 100644 --- a/src/main/java/teetime/stage/basic/merger/Merger.java +++ b/src/main/java/teetime/stage/basic/merger/Merger.java @@ -73,15 +73,6 @@ public class Merger<T> extends AbstractStage { signalMap.put(signal.getClass(), 1); } - // if (0 == finishedInputPorts) { - // signal.trigger(this); - // } - // this.finishedInputPorts++; - // - // if (this.finishedInputPorts == this.getInputPorts().length) { - // this.outputPort.sendSignal(signal); - // this.finishedInputPorts = 0; - // } } public IMergerStrategy<T> getMergerStrategy() {