Skip to content
Snippets Groups Projects
Commit 54eb7279 authored by Christian Wulf's avatar Christian Wulf
Browse files

minor refactoring

parent c6c57bf6
No related branches found
No related tags found
No related merge requests found
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
*/ */
package teetime.framework; package teetime.framework;
import java.lang.reflect.Array; import java.util.Arrays;
import java.util.HashSet; import java.util.HashSet;
import java.util.List; import java.util.List;
import java.util.Set; import java.util.Set;
...@@ -130,7 +130,7 @@ public abstract class AbstractStage extends Stage { ...@@ -130,7 +130,7 @@ public abstract class AbstractStage extends Stage {
protected <T> InputPort<T> createInputPort() { protected <T> InputPort<T> createInputPort() {
final InputPort<T> inputPort = new InputPort<T>(this); final InputPort<T> inputPort = new InputPort<T>(this);
// inputPort.setType(portType); // inputPort.setType(portType);
inputPorts = addElementToArray(inputPort, inputPorts, InputPort.class); inputPorts = addElementToArray(inputPort, inputPorts);
return inputPort; return inputPort;
} }
...@@ -142,14 +142,12 @@ public abstract class AbstractStage extends Stage { ...@@ -142,14 +142,12 @@ public abstract class AbstractStage extends Stage {
protected <T> OutputPort<T> createOutputPort() { protected <T> OutputPort<T> createOutputPort() {
final OutputPort<T> outputPort = new OutputPort<T>(); final OutputPort<T> outputPort = new OutputPort<T>();
// outputPort.setType(portType); // outputPort.setType(portType);
outputPorts = addElementToArray(outputPort, outputPorts, OutputPort.class); outputPorts = addElementToArray(outputPort, outputPorts);
return outputPort; return outputPort;
} }
private <T> T[] addElementToArray(final T element, final T[] srcArray, final Class<T> arrayType) { private <T> T[] addElementToArray(final T element, final T[] srcArray) {
@SuppressWarnings("unchecked") T[] newOutputPorts = Arrays.copyOf(srcArray, srcArray.length + 1);
T[] newOutputPorts = (T[]) Array.newInstance(arrayType, srcArray.length + 1);
System.arraycopy(srcArray, 0, newOutputPorts, 0, srcArray.length);
newOutputPorts[srcArray.length] = element; newOutputPorts[srcArray.length] = element;
return newOutputPorts; return newOutputPorts;
} }
......
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