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

refactored merger test

parent 8ffbdaed
No related branches found
No related tags found
No related merge requests found
wiki @ 0e447457
Subproject commit 63ccbbc87bd2c0e6599ca91502149dba3cfb99de Subproject commit 0e4474577e1f49bc96e734c286b2d9e0363895e8
...@@ -20,6 +20,7 @@ import static org.hamcrest.Matchers.empty; ...@@ -20,6 +20,7 @@ import static org.hamcrest.Matchers.empty;
import static org.hamcrest.Matchers.is; import static org.hamcrest.Matchers.is;
import static org.hamcrest.Matchers.not; import static org.hamcrest.Matchers.not;
import static org.junit.Assert.assertThat; import static org.junit.Assert.assertThat;
import static teetime.framework.test.StageTester.test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
...@@ -29,7 +30,6 @@ import org.junit.Test; ...@@ -29,7 +30,6 @@ import org.junit.Test;
import teetime.framework.pipe.IPipeFactory; import teetime.framework.pipe.IPipeFactory;
import teetime.framework.pipe.SingleElementPipeFactory; import teetime.framework.pipe.SingleElementPipeFactory;
import teetime.framework.test.StageTester;
import teetime.stage.CollectorSink; import teetime.stage.CollectorSink;
import teetime.stage.InitialElementProducer; import teetime.stage.InitialElementProducer;
...@@ -81,11 +81,11 @@ public class MergerTest { ...@@ -81,11 +81,11 @@ public class MergerTest {
@Test @Test
public void roundRobinShouldWork2() { public void roundRobinShouldWork2() {
mergerUnderTest = new Merger<Integer>(); mergerUnderTest = new Merger<Integer>(new RoundRobinStrategy());
mergerUnderTest.setStrategy(new RoundRobinStrategy());
List<Integer> outputList = new ArrayList<Integer>(); List<Integer> outputList = new ArrayList<Integer>();
StageTester.test(mergerUnderTest).and().send(1, 2, 3).to(mergerUnderTest.getNewInputPort()) test(mergerUnderTest)
.and().send(1, 2, 3).to(mergerUnderTest.getNewInputPort())
.and().send(4, 5, 6).to(mergerUnderTest.getNewInputPort()) .and().send(4, 5, 6).to(mergerUnderTest.getNewInputPort())
.and().receive(outputList); .and().receive(outputList);
......
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