@Override
        public void onSubscribe(final Subscription s) {
            super.onSubscribe(s);
            s.request(Integer.MAX_VALUE);
        }
A Subscriber that immediately requests Integer.MAX_VALUE onSubscribe

@param <T> The publishers result type
agent-module/agent-testweb/mongodb-reactive-plugin-testweb/src/main/java/com/pinpoint/test/plugin/SubscriberHelpers.java