... | @@ -78,10 +78,10 @@ public class CounterTest { |
... | @@ -78,10 +78,10 @@ public class CounterTest { |
|
Clazz clazz = new Clazz();
|
|
Clazz clazz = new Clazz();
|
|
Integer number = 42;
|
|
Integer number = 42;
|
|
|
|
|
|
test(filter)
|
|
test(filter).and()
|
|
.and().send(clazz, number, clazz).to(filter.getInputPort())
|
|
.send(clazz, number, clazz).to(filter.getInputPort()).and()
|
|
.and().receive(matchedElements).from(filter.getMatchedOutputPort())
|
|
.receive(matchedElements).from(filter.getMatchedOutputPort()).and()
|
|
.and().receive(mismatchedElements).from(filter.getMismatchedOutputPort())
|
|
.receive(mismatchedElements).from(filter.getMismatchedOutputPort()).and()
|
|
.start();
|
|
.start();
|
|
|
|
|
|
assertThat(matchedElements, contains(clazz, clazz));
|
|
assertThat(matchedElements, contains(clazz, clazz));
|
... | @@ -102,7 +102,7 @@ public class CounterTest { |
... | @@ -102,7 +102,7 @@ public class CounterTest { |
|
List<Integer> outputElements = new ArrayList<>();
|
|
List<Integer> outputElements = new ArrayList<>();
|
|
|
|
|
|
test(producer)
|
|
test(producer)
|
|
.receive(outputElements).from(producer.getOutputPort())
|
|
.receive(outputElements).from(producer.getOutputPort()).and()
|
|
.start();
|
|
.start();
|
|
|
|
|
|
assertThat(outputElements, contains(1, 2, 3));
|
|
assertThat(outputElements, contains(1, 2, 3));
|
... | | ... | |