diff --git a/src/test/java/teetime/stage/basic/merger/MergerTest.java b/src/test/java/teetime/stage/basic/merger/MergerTest.java index 9ec29159adb89a073801393d87d8341e8b0790fa..c5094692edb0aa95bbefb4e70ede9304e1d4015c 100644 --- a/src/test/java/teetime/stage/basic/merger/MergerTest.java +++ b/src/test/java/teetime/stage/basic/merger/MergerTest.java @@ -87,9 +87,9 @@ public class MergerTest { test(mergerUnderTest) .and().send(1, 2, 3).to(mergerUnderTest.getNewInputPort()) .and().send(4, 5, 6).to(mergerUnderTest.getNewInputPort()) - .and().receive(outputList); + .and().receive(outputList).from(mergerUnderTest.getOutputPort()).start(); assertThat(outputList, is(not(empty()))); - assertThat(outputList, contains(1, 2, 3, 4, 5, 6)); + assertThat(outputList, contains(1, 4, 2, 5, 3, 6)); } }