@Test
public void testNoBackpressure() {

    ArrayList<Integer> list = new ArrayList<Integer>(RxRingBuffer.SIZE * 2);
    for (int i = 1; i <= RxRingBuffer.SIZE * 2 + 1; i++) {
        list.add(i);
    }
    OnSubscribeRange o = new OnSubscribeRange(1, list.size());
    TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
    ts.assertReceivedOnNext(Collections.<Integer> emptyList());
    ts.requestMore(Long.MAX_VALUE); // infinite
    o.call(ts);
    ts.assertReceivedOnNext(list);
    ts.assertTerminalEvent();
}