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

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