diff --git a/src/test/java/teetime/stage/basic/merger/MergerTest.java b/src/test/java/teetime/stage/basic/merger/MergerTest.java index c5094692edb0aa95bbefb4e70ede9304e1d4015c..7a8546090157a8195799a53abfd11861109ed605 100644 --- a/src/test/java/teetime/stage/basic/merger/MergerTest.java +++ b/src/test/java/teetime/stage/basic/merger/MergerTest.java @@ -23,6 +23,7 @@ import static org.junit.Assert.assertThat; import static teetime.framework.test.StageTester.test; import java.util.ArrayList; +import java.util.Collection; import java.util.List; import org.junit.Before; @@ -32,6 +33,7 @@ import teetime.framework.pipe.IPipeFactory; import teetime.framework.pipe.SingleElementPipeFactory; import teetime.stage.CollectorSink; import teetime.stage.InitialElementProducer; +import teetime.util.Pair; /** * @author Nils Christian Ehmke @@ -84,11 +86,13 @@ public class MergerTest { mergerUnderTest = new Merger<Integer>(new RoundRobinStrategy()); List<Integer> outputList = new ArrayList<Integer>(); - test(mergerUnderTest) + Collection<Pair<Thread, Throwable>> exceptions = test(mergerUnderTest) .and().send(1, 2, 3).to(mergerUnderTest.getNewInputPort()) .and().send(4, 5, 6).to(mergerUnderTest.getNewInputPort()) - .and().receive(outputList).from(mergerUnderTest.getOutputPort()).start(); + .and().receive(outputList).from(mergerUnderTest.getOutputPort()) + .start(); + assertThat(exceptions, is(empty())); assertThat(outputList, is(not(empty()))); assertThat(outputList, contains(1, 4, 2, 5, 3, 6)); }