Skip to content
Snippets Groups Projects
Commit 4d54b43f authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

clean-up

parent 41f0a1a9
No related branches found
No related tags found
No related merge requests found
......@@ -28,8 +28,8 @@ import teetime.util.framework.port.PortList;
import teetime.util.framework.port.PortRemovedListener;
public abstract class AbstractStage extends Stage {
private final Map<Class<? extends ISignal>, Set<InputPort<?>>> signalMap = new HashMap<Class<? extends ISignal>, Set<InputPort<?>>>();
private final Map<Class<? extends ISignal>, Set<InputPort<?>>> signalMap = new HashMap<Class<? extends ISignal>, Set<InputPort<?>>>();
private final Set<Class<? extends ISignal>> triggeredSignalTypes = new HashSet<Class<? extends ISignal>>();
private final PortList<InputPort<?>> inputPorts = new PortList<InputPort<?>>();
......
......@@ -15,10 +15,7 @@
*/
package teetime.stage.basic.merger;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import teetime.framework.AbstractStage;
import teetime.framework.InputPort;
......@@ -41,7 +38,6 @@ import teetime.stage.basic.merger.strategy.RoundRobinStrategy;
*/
public class Merger<T> extends AbstractStage {
private final Map<Class<? extends ISignal>, Set<InputPort<?>>> signalMap;
private final OutputPort<T> outputPort = this.createOutputPort();
private final IMergerStrategy strategy;
......@@ -51,7 +47,6 @@ public class Merger<T> extends AbstractStage {
}
public Merger(final IMergerStrategy strategy) {
this.signalMap = new HashMap<Class<? extends ISignal>, Set<InputPort<?>>>();
this.strategy = strategy;
addInputPortRemovedListener(strategy);
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment