@Override
        public void onError(Throwable throwable) {
            logger.error("Error processing stream [" + s + "]", throwable);
        }
Returns the input type of the stream that is to be processed
spring-xd-reactor/src/main/java/org/springframework/xd/reactor/AbstractReactorMessageHandler.java