Interface BaseStream<T, S extends BaseStream<T,S>>

Type Parameters:
T - the type of the stream elements
S - the type of the stream implementingBaseStream
All Superinterfaces:
AutoCloseable
All Known Subinterfaces:
DoubleStream,IntStream,LongStream,Stream<T>
public interfaceBaseStream<T, S extends BaseStream<T,S>>extendsAutoCloseable
Base interface for streams, which are sequences of elements supporting sequential and parallel aggregate operations. The following example illustrates an aggregate operation using the stream typesStream andIntStream, computing the sum of the weights of the red widgets:
     int sum = widgets.stream()                      .filter(w -> w.getColor() == RED)                      .mapToInt(w -> w.getWeight())                      .sum();
See the class documentation forStream and the package documentation forjava.util.stream for additional specification of streams, stream operations, stream pipelines, and parallelism, which governs the behavior of all stream types.
Since:
1.8
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Closes this stream, causing all close handlers for this stream pipeline to be called.
    boolean
    Returns whether this stream, if a terminal operation were to be executed, would execute in parallel.
    Returns an iterator for the elements of this stream.
    onClose(Runnable closeHandler)
    Returns an equivalent stream with an additional close handler.
    Returns an equivalent stream that is parallel.
    Returns an equivalent stream that is sequential.
    Returns a spliterator for the elements of this stream.
    Returns an equivalent stream that isunordered.

  • Method Details

    • iterator

      Iterator<T> iterator()
      Returns an iterator for the elements of this stream.

      This is aterminal operation.

      API Note:
      This operation is provided as an "escape hatch" to enable arbitrary client-controlled pipeline traversals in the event that the existing operations are not sufficient to the task.
      Returns:
      the element iterator for this stream

    • spliterator

      Spliterator<T> spliterator()
      Returns a spliterator for the elements of this stream.

      This is aterminal operation.

      API Note:
      This operation is provided as an "escape hatch" to enable arbitrary client-controlled pipeline traversals in the event that the existing operations are not sufficient to the task.

      The returned spliterator should report the set of characteristics derived from the stream pipeline (namely the characteristics derived from the stream source spliterator and the intermediate operations). Implementations may report a sub-set of those characteristics. For example, it may be too expensive to compute the entire set for some or all possible stream pipelines.

      Returns:
      the element spliterator for this stream

    • isParallel

      boolean isParallel()
      Returns whether this stream, if a terminal operation were to be executed, would execute in parallel. Calling this method after invoking an terminal stream operation method may yield unpredictable results.
      Returns:
      true if this stream would execute in parallel if executed

    • sequential

      S sequential()
      Returns an equivalent stream that is sequential. May return itself, either because the stream was already sequential, or because the underlying stream state was modified to be sequential.

      This is anintermediate operation.

      Returns:
      a sequential stream

    • parallel

      S parallel()
      Returns an equivalent stream that is parallel. May return itself, either because the stream was already parallel, or because the underlying stream state was modified to be parallel.

      This is anintermediate operation.

      Returns:
      a parallel stream

    • unordered

      S unordered()
      Returns an equivalent stream that isunordered. May return itself, either because the stream was already unordered, or because the underlying stream state was modified to be unordered.

      This is anintermediate operation.

      Returns:
      an unordered stream

    • onClose

      S onClose(Runnable closeHandler)
      Returns an equivalent stream with an additional close handler. Close handlers are run when theclose() method is called on the stream, and are executed in the order they were added. All close handlers are run, even if earlier close handlers throw exceptions. If any close handler throws an exception, the first exception thrown will be relayed to the caller ofclose(), with any remaining exceptions added to that exception as suppressed exceptions (unless one of the remaining exceptions is the same exception as the first exception, since an exception cannot suppress itself.) May return itself.

      This is anintermediate operation.

      Parameters:
      closeHandler - A task to execute when the stream is closed
      Returns:
      a stream with a handler that is run if the stream is closed

    • close

      void close()
      Closes this stream, causing all close handlers for this stream pipeline to be called.
      Specified by:
      close in interface AutoCloseable
      See Also: