diff --git a/src/test/java/teetime/stage/basic/merger/MergerPipeWithTargetPort.java b/src/test/java/teetime/stage/basic/merger/MergerPipeWithTargetPort.java index eeef74da72fcce33c3395bf772238c8f19c2908f..80d1baa5b8f33af4849ea4f8aabf6759c920216e 100644 --- a/src/test/java/teetime/stage/basic/merger/MergerPipeWithTargetPort.java +++ b/src/test/java/teetime/stage/basic/merger/MergerPipeWithTargetPort.java @@ -1,7 +1,7 @@ package teetime.stage.basic.merger; -import teetime.framework.AbstractPipe; import teetime.framework.AbstractInputPort; +import teetime.framework.AbstractPipe; import teetime.framework.signal.ISignal; final class MergerPipeWithTargetPort<T> extends AbstractPipe { @@ -28,6 +28,12 @@ final class MergerPipeWithTargetPort<T> extends AbstractPipe { return false; } + @SuppressWarnings("unchecked") + @Override + public AbstractInputPort<T> getTargetPort() { + return (AbstractInputPort<T>) super.getTargetPort(); + } + @Override public int size() { // TODO Auto-generated method stub diff --git a/src/test/java/teetime/stage/basic/merger/MergerSignalTest.java b/src/test/java/teetime/stage/basic/merger/MergerSignalTest.java index 83995d1f8f8bcd1d826db3745e699c5303c0aa11..b5170f0b0ecd5d9626c6a58473fe96cbac21ea12 100644 --- a/src/test/java/teetime/stage/basic/merger/MergerSignalTest.java +++ b/src/test/java/teetime/stage/basic/merger/MergerSignalTest.java @@ -33,17 +33,16 @@ public class MergerSignalTest { private AbstractInputPort<Integer> secondPort; private MergerTestingPipe testPipe; - @SuppressWarnings("unchecked") public void beforeSignalTesting() { merger = new Merger<Integer>(); AbstractInputPort<Integer> mergerInputPort = merger.getDynamicInputPort(); MergerPipeWithTargetPort<Integer> pipe0 = new MergerPipeWithTargetPort<Integer>(mergerInputPort); - firstPort = (AbstractInputPort<Integer>) pipe0.getTargetPort(); + firstPort = pipe0.getTargetPort(); MergerPipeWithTargetPort<Integer> pipe1 = new MergerPipeWithTargetPort<Integer>(mergerInputPort); - secondPort = (AbstractInputPort<Integer>) pipe1.getTargetPort(); + secondPort = pipe1.getTargetPort(); testPipe = new MergerTestingPipe(merger.getOutputPort()); }