diff --git a/jdk/src/share/classes/java/util/stream/AbstractPipeline.java b/jdk/src/share/classes/java/util/stream/AbstractPipeline.java index efda9407152..bde7efb1f80 100644 --- a/jdk/src/share/classes/java/util/stream/AbstractPipeline.java +++ b/jdk/src/share/classes/java/util/stream/AbstractPipeline.java @@ -53,11 +53,6 @@ import java.util.function.Supplier; * operation, the stream is considered to be consumed, and no more intermediate * or terminal operations are permitted on this stream instance. * - *

{@code AbstractPipeline} implements a number of methods that are - * specified in {@link BaseStream}, though it does not implement - * {@code BaseStream} directly. Subclasses of {@code AbstractPipeline} - * will generally implement {@code BaseStream}. - * * @implNote *

For sequential streams, and parallel streams without * stateful intermediate @@ -75,7 +70,7 @@ import java.util.function.Supplier; * @since 1.8 */ abstract class AbstractPipeline> - extends PipelineHelper { + extends PipelineHelper implements BaseStream { /** * Backlink to the head of the pipeline chain (self if this is the source * stage). @@ -286,26 +281,20 @@ abstract class AbstractPipeline> // BaseStream - /** - * Implements {@link BaseStream#sequential()} - */ + @Override public final S sequential() { sourceStage.parallel = false; return (S) this; } - /** - * Implements {@link BaseStream#parallel()} - */ + @Override public final S parallel() { sourceStage.parallel = true; return (S) this; } // Primitive specialization use co-variant overrides, hence is not final - /** - * Implements {@link BaseStream#spliterator()} - */ + @Override public Spliterator spliterator() { if (linkedOrConsumed) throw new IllegalStateException("stream has already been operated upon"); @@ -331,9 +320,7 @@ abstract class AbstractPipeline> } } - /** - * Implements {@link BaseStream#isParallel()} - */ + @Override public final boolean isParallel() { return sourceStage.parallel; } diff --git a/jdk/src/share/classes/java/util/stream/BaseStream.java b/jdk/src/share/classes/java/util/stream/BaseStream.java index db002b5c031..94dbc7de73f 100644 --- a/jdk/src/share/classes/java/util/stream/BaseStream.java +++ b/jdk/src/share/classes/java/util/stream/BaseStream.java @@ -29,15 +29,13 @@ import java.util.Spliterator; /** * Base interface for stream types such as {@link Stream}, {@link IntStream}, - * etc. Contains methods common to all stream types. Many of these methods - * are implemented by {@link AbstractPipeline}, even though - * {@code AbstractPipeline} does not directly implement {@code BaseStream}. + * etc. Contains methods common to all stream types. * * @param type of stream elements * @param type of stream implementing {@code BaseStream} * @since 1.8 */ -interface BaseStream> { +public interface BaseStream> { /** * Returns an iterator for the elements of this stream. *