diff --git a/src/test/java/teetime/framework/pipe/SpScPipeTest.java b/src/test/java/teetime/framework/pipe/SpScPipeTest.java index 37c2e9647842bd7a653654d33a7aea610f54b044..5b06fa1e574a277a361c4c09ad26d990d5e061c0 100644 --- a/src/test/java/teetime/framework/pipe/SpScPipeTest.java +++ b/src/test/java/teetime/framework/pipe/SpScPipeTest.java @@ -15,6 +15,7 @@ */ package teetime.framework.pipe; +import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import java.util.ArrayList; @@ -29,15 +30,17 @@ import teetime.framework.signal.ISignal; import teetime.framework.signal.StartingSignal; import teetime.framework.signal.TerminatingSignal; import teetime.framework.signal.ValidatingSignal; +import teetime.stage.basic.merger.Merger; public class SpScPipeTest { // @Ignore // ignore as long as this test passes null ports to SpScPipe - // @Test + @Test public void testSignalOrdering() throws Exception { - OutputPort<Object> sourcePort = null; - InputPort<Object> targetPort = null; + Merger<Object> portSource = new Merger<Object>(); + OutputPort<Object> sourcePort = portSource.getOutputPort(); + InputPort<Object> targetPort = portSource.getNewInputPort(); AbstractInterThreadPipe pipe = new SpScPipe(sourcePort, targetPort, 1); // IPipe does not provide getSignal method List<ISignal> signals = new ArrayList<ISignal>(); @@ -63,7 +66,7 @@ public class SpScPipeTest { } secondSignals.add(temp); } - // Assert.assertEquals(list, secondList); + assertEquals(signals, secondSignals); } @Test(expected = NullPointerException.class)