RFR 8017329 8b92-lambda regression: TreeSet("a", "b").stream().substream(1).parallel().iterator() is empty (original) (raw)

Thu Jun 27 09:38:39 UTC 2013

           // It is necessary to truncate here since the result at the root
           // can only be set once
           return doTruncate(nb.build());
           // There is no need to truncate since the op performs the
           // skipping and limiting of elements
           return nb.build();
       }
       else {
           Node<P_OUT> node = helper.wrapAndCopyInto(helper.makeNodeBuilder(-1, generator),
   class NonSplittingNotSubsizedOrderedSpliterator<T> implements Spliterator<T> {
       Spliterator<T> s;
       NonSplittingNotSubsizedOrderedSpliterator(Spliterator<T> s) {
           assert s.hasCharacteristics(Spliterator.ORDERED);
           this.s = s;
       }
       @Override
       public boolean tryAdvance(Consumer<? super T> action) {
           return s.tryAdvance(action);
       }
       @Override
       public void forEachRemaining(Consumer<? super T> action) {
           s.forEachRemaining(action);
       }
       @Override
       public Spliterator<T> trySplit() {
           return null;
       }
       @Override
       public long estimateSize() {
           return s.estimateSize();
       }
       @Override
       public int characteristics() {
           return s.characteristics() & ~(Spliterator.SUBSIZED);
       }
       @Override
       public Comparator<? super T> getComparator() {
           return s.getComparator();
       }
   }
   List<Integer> list = IntStream.range(0, 100).boxed().collect(Collectors.toList());
   TestData.OfRef<Integer> data = TestData.Factory.ofSupplier(
           "Non splitting, not SUBSIZED, ORDERED, stream",
           () -> StreamSupport.stream(new NonSplittingNotSubsizedOrderedSpliterator<>(list.spliterator())));
   testSkipLimitOps("testSkipLimitOpsWithNonSplittingSpliterator", data);
@Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class)
public void testLimitOps(String name, TestData.OfRef<Integer> data) {
    List<Integer> limits = sizes(data.size());

RFR 8017329 8b92-lambda regression: TreeSet("a", "b").stream().substream(1).parallel().iterator() is empty (original) (raw)

HG changeset patch

User psandoz

Date 1372324256 -7200

Node ID 3459ac0d695ffdf2f5120e63a9a4bb79a0af40dc

Parent d4cd5e16ac8f279e05974cdb2f6281c5f24e484c