@Test @Timeout(5) public void testToIterable() { List<Integer> values = new ArrayList<>(); for (Integer i : Multi.createFrom().range(1, 11).subscribe().asIterable()) { values.add(i); } assertThat(values).containsExactly(1, 2, 3, 4, 5, 6, 7, 8, 9, 10); values.clear(); Multi.createFrom().range(1, 11).subscribe().asIterable().spliterator().forEachRemaining(values::add); assertThat(values).containsExactly(1, 2, 3, 4, 5, 6, 7, 8, 9, 10); }
@Override public Spliterator<T> spliterator() { return stream().spliterator(); }
BlockingIterable implements Iterable<T> { @Override public Spliterator<T> spliterator() { return stream().spliterator(); } }
BlockingIterable implements Iterable<T> { @Override public Spliterator<T> spliterator() { return stream().spliterator(); } BlockingIterable(Publisher<? extends T> upstream, int batchSize, Supplier<Queue<T>> supplier); }
BlockingIterable implements Iterable<T> { @Override public Spliterator<T> spliterator() { return stream().spliterator(); } BlockingIterable(Publisher<? extends T> upstream, int batchSize, Supplier<Queue<T>> supplier); @Override Iterator<T> iterator(); @Override Spliterator<T> spliterator(); Stream<T> stream(); }
BlockingIterable implements Iterable<T> { @Override public Spliterator<T> spliterator() { return stream().spliterator(); } BlockingIterable(Publisher<? extends T> upstream, int batchSize, Supplier<Queue<T>> supplier); @Override Iterator<T> iterator(); @Override Spliterator<T> spliterator(); Stream<T> stream();  }