@Test
public void requestMaxInt() {

    QueueDrainHelper.request(new Subscription() {
        @Override
        public void request(long n) {
            assertEquals(Integer.MAX_VALUE, n);
        }
        @Override
        public void cancel() {
        }
    }, Integer.MAX_VALUE);
}