@Override
    public Stream<String> process(Stream<String> inputStream) {
        return inputStream.map(new Function<String, String>() {
            @Override
            public String apply(String message) {
                return message + "-stringpong";
            }
        });
    }
A simple stream processor that transforms Strings by adding "-pong" to the string.

@author Mark Pollack
spring-xd-reactor/src/test/java/org/springframework/xd/reactor/PongStringProcessor.java