@Test public void testNoBackpressure() { OnSubscribeFromIterable<Integer> o = new OnSubscribeFromIterable<Integer>(Arrays.asList(1, 2, 3, 4, 5)); TestSubscriber<Integer> ts = new TestSubscriber<Integer>(); ts.assertReceivedOnNext(Collections.<Integer> emptyList()); ts.requestMore(Long.MAX_VALUE); o.call(ts); ts.assertReceivedOnNext(Arrays.asList(1, 2, 3, 4, 5)); ts.assertTerminalEvent(); }
@Override public void call(final Subscriber<? super T> o) { final Iterator<? extends T> it = is.iterator(); o.setProducer(new IterableProducer<T>(o, it)); }
OnSubscribeFromIterable implements OnSubscribe<T> { @Override public void call(final Subscriber<? super T> o) { final Iterator<? extends T> it = is.iterator(); o.setProducer(new IterableProducer<T>(o, it)); } }
OnSubscribeFromIterable implements OnSubscribe<T> { @Override public void call(final Subscriber<? super T> o) { final Iterator<? extends T> it = is.iterator(); o.setProducer(new IterableProducer<T>(o, it)); } OnSubscribeFromIterable(Iterable<? extends T> iterable); }
OnSubscribeFromIterable implements OnSubscribe<T> { @Override public void call(final Subscriber<? super T> o) { final Iterator<? extends T> it = is.iterator(); o.setProducer(new IterableProducer<T>(o, it)); } OnSubscribeFromIterable(Iterable<? extends T> iterable); @Override void call(final Subscriber<? super T> o); }
OnSubscribeFromIterable implements OnSubscribe<T> { @Override public void call(final Subscriber<? super T> o) { final Iterator<? extends T> it = is.iterator(); o.setProducer(new IterableProducer<T>(o, it)); } OnSubscribeFromIterable(Iterable<? extends T> iterable); @Override void call(final Subscriber<? super T> o);  }