class 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());
    }

}