@Override
        public void onSubscribe(Subscription s) {
            this.s = s;
            s.request(Long.MAX_VALUE);
        }
Returns the input type of the stream that is to be processed
spring-xd-reactor/src/main/java/org/springframework/xd/reactor/AbstractReactorMessageHandler.java