src/share/classes/java/util/stream/Stream.java

rev 7627 : 8015315: Stream.concat methods
Reviewed-by: psandoz
Contributed-by: brian.goetz@oracle.com, henry.jen@oracle.com
rev 7630 : 8019395: Consolidate StreamSupport.{stream,parallelStream} into a single method
Reviewed-by: henryjen
rev 7631 : 8020062: Nest StreamBuilder interfaces inside relevant Stream interfaces
Reviewed-by: psandoz
Contributed-by: brian goetz <brian.goetz@oracle.com>
rev 7632 : 8015318: Extend Collector with 'finish' operation
Reviewed-by:
Contributed-by: brian.goetz@oracle.com
rev 7633 : 8017513: Support for closeable streams
Reviewed-by:
Contributed-by: brian.goetz@oracle.com

*** 888,898 ****
      /**
       * Creates a lazy concatenated {@code Stream} whose elements are all the
       * elements of a first {@code Stream} succeeded by all the elements of the
       * second {@code Stream}. The resulting stream is ordered if both
       * of the input streams are ordered, and parallel if either of the input
!      * streams is parallel.
       *
       * @param <T> The type of stream elements
       * @param a the first stream
       * @param b the second stream to concatenate on to end of the first
       *        stream
--- 888,899 ----
      /**
       * Creates a lazy concatenated {@code Stream} whose elements are all the
       * elements of a first {@code Stream} succeeded by all the elements of the
       * second {@code Stream}. The resulting stream is ordered if both
       * of the input streams are ordered, and parallel if either of the input
!      * streams is parallel.  When the resulting stream is closed, the close
!      * handlers for both input streams is invoked.
       *
       * @param <T> The type of stream elements
       * @param a the first stream
       * @param b the second stream to concatenate on to end of the first
       *        stream
*** 903,913 ****
          Objects.requireNonNull(b);
  
          @SuppressWarnings("unchecked")
          Spliterator<T> split = new Streams.ConcatSpliterator.OfRef<>(
                  (Spliterator<T>) a.spliterator(), (Spliterator<T>) b.spliterator());
!         return StreamSupport.stream(split, a.isParallel() || b.isParallel());
      }
  
      /**
       * A mutable builder for a {@code Stream}.  This allows the creation of a
       * {@code Stream} by generating elements individually and adding them to the
--- 904,915 ----
          Objects.requireNonNull(b);
  
          @SuppressWarnings("unchecked")
          Spliterator<T> split = new Streams.ConcatSpliterator.OfRef<>(
                  (Spliterator<T>) a.spliterator(), (Spliterator<T>) b.spliterator());
!         Stream<T> stream = StreamSupport.stream(split, a.isParallel() || b.isParallel());
!         return stream.onClose(Streams.composedClose(a, b));
      }
  
      /**
       * A mutable builder for a {@code Stream}.  This allows the creation of a
       * {@code Stream} by generating elements individually and adding them to the