UniqueFilter extends AbstractConsumerStage<String> { public OutputPort<String> getOutputPort() { return this.outputPort; } UniqueFilter(); OutputPort<String> getOutputPort();  }
@Test public void testExecuteString() { final List<String> outputList = new ArrayList<>(); StageTester.test(this.uniqueFilter).and().send(this.inputList).to(this.uniqueFilter.getInputPort()).and() .receive(outputList).from(this.uniqueFilter.getOutputPort()).start(); Assert.assertEquals("Not the correct number of results.", this.expectedOutputList.size(), outputList.size()); for (int i = 0; i < this.expectedOutputList.size(); i++) { Assert.assertEquals("Not the same values.", this.expectedOutputList.get(i), outputList.get(i)); } }