--- a/jdk/src/share/classes/java/util/stream/Stream.java Fri Jul 12 12:15:59 2013 -0700
+++ b/jdk/src/share/classes/java/util/stream/Stream.java Wed Jul 03 21:43:49 2013 +0200
@@ -805,7 +805,7 @@
* @return an empty sequential stream
*/
public static<T> Stream<T> empty() {
- return StreamSupport.stream(Spliterators.<T>emptySpliterator());
+ return StreamSupport.stream(Spliterators.<T>emptySpliterator(), false);
}
/**
@@ -816,7 +816,7 @@
* @return a singleton sequential stream
*/
public static<T> Stream<T> of(T t) {
- return StreamSupport.stream(new Streams.StreamBuilderImpl<>(t));
+ return StreamSupport.stream(new Streams.StreamBuilderImpl<>(t), false);
}
/**
@@ -866,7 +866,7 @@
};
return StreamSupport.stream(Spliterators.spliteratorUnknownSize(
iterator,
- Spliterator.ORDERED | Spliterator.IMMUTABLE));
+ Spliterator.ORDERED | Spliterator.IMMUTABLE), false);
}
/**
@@ -881,7 +881,7 @@
public static<T> Stream<T> generate(Supplier<T> s) {
Objects.requireNonNull(s);
return StreamSupport.stream(
- new StreamSpliterators.InfiniteSupplyingSpliterator.OfRef<>(Long.MAX_VALUE, s));
+ new StreamSpliterators.InfiniteSupplyingSpliterator.OfRef<>(Long.MAX_VALUE, s), false);
}
/**
@@ -904,8 +904,6 @@
@SuppressWarnings("unchecked")
Spliterator<T> split = new Streams.ConcatSpliterator.OfRef<>(
(Spliterator<T>) a.spliterator(), (Spliterator<T>) b.spliterator());
- return (a.isParallel() || b.isParallel())
- ? StreamSupport.parallelStream(split)
- : StreamSupport.stream(split);
+ return StreamSupport.stream(split, a.isParallel() || b.isParallel());
}
}