### Question:
ProcessorFlowsFactory implements FlowsFactory { @Override public Collection<String> getInputFlows() { return getListener() .map(m -> Stream.of(m.getParameters())) .orElseGet(() -> getAfterGroup().map(it -> Stream.of(it.getParameters())).orElseGet(Stream::empty)) .filter(this::isInput) .map(this::mapInputName) .collect(toList()); }  @Override Collection<String> getInputFlows(); @Override Collection<String> getOutputFlows();  }### Answer:
@Test void testGetInputFlows() { final ProcessorFlowsFactory factory = new ProcessorFlowsFactory(TestProcessor.class); final Collection<String> inputs = factory.getInputFlows(); assertEquals(2, inputs.size()); assertTrue(inputs.contains("__default__")); assertTrue(inputs.contains("REJECT")); }