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

refactored MergerPipeWithTargetPort

parent 4b8782bc
Branches dynamicport
No related tags found
No related merge requests found
package teetime.stage.basic.merger; package teetime.stage.basic.merger;
import teetime.framework.AbstractPipe;
import teetime.framework.AbstractInputPort; import teetime.framework.AbstractInputPort;
import teetime.framework.AbstractPipe;
import teetime.framework.signal.ISignal; import teetime.framework.signal.ISignal;
final class MergerPipeWithTargetPort<T> extends AbstractPipe { final class MergerPipeWithTargetPort<T> extends AbstractPipe {
...@@ -28,6 +28,12 @@ final class MergerPipeWithTargetPort<T> extends AbstractPipe { ...@@ -28,6 +28,12 @@ final class MergerPipeWithTargetPort<T> extends AbstractPipe {
return false; return false;
} }
@SuppressWarnings("unchecked")
@Override
public AbstractInputPort<T> getTargetPort() {
return (AbstractInputPort<T>) super.getTargetPort();
}
@Override @Override
public int size() { public int size() {
// TODO Auto-generated method stub // TODO Auto-generated method stub
... ...
......
...@@ -33,17 +33,16 @@ public class MergerSignalTest { ...@@ -33,17 +33,16 @@ public class MergerSignalTest {
private AbstractInputPort<Integer> secondPort; private AbstractInputPort<Integer> secondPort;
private MergerTestingPipe testPipe; private MergerTestingPipe testPipe;
@SuppressWarnings("unchecked")
public void beforeSignalTesting() { public void beforeSignalTesting() {
merger = new Merger<Integer>(); merger = new Merger<Integer>();
AbstractInputPort<Integer> mergerInputPort = merger.getDynamicInputPort(); AbstractInputPort<Integer> mergerInputPort = merger.getDynamicInputPort();
MergerPipeWithTargetPort<Integer> pipe0 = new MergerPipeWithTargetPort<Integer>(mergerInputPort); MergerPipeWithTargetPort<Integer> pipe0 = new MergerPipeWithTargetPort<Integer>(mergerInputPort);
firstPort = (AbstractInputPort<Integer>) pipe0.getTargetPort(); firstPort = pipe0.getTargetPort();
MergerPipeWithTargetPort<Integer> pipe1 = new MergerPipeWithTargetPort<Integer>(mergerInputPort); MergerPipeWithTargetPort<Integer> pipe1 = new MergerPipeWithTargetPort<Integer>(mergerInputPort);
secondPort = (AbstractInputPort<Integer>) pipe1.getTargetPort(); secondPort = pipe1.getTargetPort();
testPipe = new MergerTestingPipe(merger.getOutputPort()); testPipe = new MergerTestingPipe(merger.getOutputPort());
} }
... ...
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment