@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); o.call(ts); ts.assertReceivedOnNext(list); ts.assertTerminalEvent(); }
@Override public void call(final Subscriber<? super Integer> o) { o.setProducer(new RangeProducer(o, start, end)); }
OnSubscribeRange implements OnSubscribe<Integer> { @Override public void call(final Subscriber<? super Integer> o) { o.setProducer(new RangeProducer(o, start, end)); } }
OnSubscribeRange implements OnSubscribe<Integer> { @Override public void call(final Subscriber<? super Integer> o) { o.setProducer(new RangeProducer(o, start, end)); } OnSubscribeRange(int start, int end); }
OnSubscribeRange implements OnSubscribe<Integer> { @Override public void call(final Subscriber<? super Integer> o) { o.setProducer(new RangeProducer(o, start, end)); } OnSubscribeRange(int start, int end); @Override void call(final Subscriber<? super Integer> o); }
OnSubscribeRange implements OnSubscribe<Integer> { @Override public void call(final Subscriber<? super Integer> o) { o.setProducer(new RangeProducer(o, start, end)); } OnSubscribeRange(int start, int end); @Override void call(final Subscriber<? super Integer> o);  }