@Test public void nullIteratorValue() { TestSubscriber<Object> ts = new TestSubscriber<>(); Single.<Integer>just(1) .flatMapIterable(v -> Collections.singletonList(null)) .subscribe(ts); ts.assertEmpty() .request(1) .assertFailure(NullPointerException.class); }
@Override public void subscribe(Flow.Subscriber<? super R> subscriber) { source.subscribe(new FlatMapIterableSubscriber<>(subscriber, mapper)); }
SingleFlatMapIterable implements Multi<R> { @Override public void subscribe(Flow.Subscriber<? super R> subscriber) { source.subscribe(new FlatMapIterableSubscriber<>(subscriber, mapper)); } }
SingleFlatMapIterable implements Multi<R> { @Override public void subscribe(Flow.Subscriber<? super R> subscriber) { source.subscribe(new FlatMapIterableSubscriber<>(subscriber, mapper)); } SingleFlatMapIterable(Single<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper); }
SingleFlatMapIterable implements Multi<R> { @Override public void subscribe(Flow.Subscriber<? super R> subscriber) { source.subscribe(new FlatMapIterableSubscriber<>(subscriber, mapper)); } SingleFlatMapIterable(Single<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper); @Override void subscribe(Flow.Subscriber<? super R> subscriber); }
SingleFlatMapIterable implements Multi<R> { @Override public void subscribe(Flow.Subscriber<? super R> subscriber) { source.subscribe(new FlatMapIterableSubscriber<>(subscriber, mapper)); } SingleFlatMapIterable(Single<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper); @Override void subscribe(Flow.Subscriber<? super R> subscriber);  }