Интерфейс DoubleStream

DoubleStream filter(DoublePredicate predicate)

Возвращает поток, состоящий из элементов этого потока, которые соответствуют заданному предикату.

Это промежуточная операция.

DoubleStream map(DoubleUnaryOperator mapper)

Возвращает поток, состоящий из результатов применения заданной функции к элементам этого потока.

Это промежуточная операция.

<U> Stream<U> mapToObj(DoubleFunction<? extends U> mapper)

Возвращает Stream со значениями объектов, полученными в результате применения заданной функции к элементам этого потока.

Это промежуточная операция.

IntStream mapToInt(DoubleToIntFunction mapper)

Возвращает IntStream, состоящий из результатов применения заданной функции к элементам этого потока.

Это промежуточная операция.

LongStream mapToLong(DoubleToLongFunction mapper)

Возвращает LongStream, состоящий из результатов применения заданной функции к элементам этого потока.

Это промежуточная операция.

DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

Возвращает поток, содержащий результаты замены каждого элемента этого потока содержимым отображенного потока, полученного путем применения предоставленной функции отображения к каждому элементу. Каждый отображенный поток closed после того, как его содержимое было помещено в этот поток. (Если отображенный поток null используется пустой поток.)

Это промежуточная операция.

default DoubleStream mapMulti(DoubleStream.DoubleMapMultiConsumer mapper)

Возвращает поток, содержащий результаты замены каждого элемента этого потока множеством элементов (ноль или более). Замена выполняется путем применения предоставленной функции отображения к каждому элементу совместно с аргументом потребителя, принимающим элементы замены. Функция отображения вызывает потребителя ноль или более раз для предоставления элементов замены.

Это промежуточная операция.

Если аргумент потребителя используется за пределами области его применения к функции отображения, результаты не определены.

DoubleStream distinct()

Возвращает поток, содержащий уникальные элементы этого потока. Элементы сравниваются на равенство в соответствии с Double.compare(double, double).

Это состоятельная промежуточная операция.

DoubleStream sorted()

Возвращает поток, содержащий элементы этого потока в отсортированном порядке. Элементы сравниваются на равенство в соответствии с Double.compare(double, double).

Это состоятельная промежуточная операция.

DoubleStream peek(DoubleConsumer action)

Возвращает поток, содержащий элементы этого потока, дополнительно выполняя указанное действие над каждым элементом по мере потребления элементов из результирующего потока.

Это промежуточная операция.

Для параллельных потоковых конвейеров действие может быть вызвано в любое время и в любом потоке, в котором элемент становится доступным от операции потока-предшественника. Если действие изменяет общие данные, оно отвечает за обеспечение необходимой синхронизации.

DoubleStream limit(long maxSize)

Возвращает поток, содержащий элементы этого потока, усеченные до длины не более maxSize.

Это краткосрочная состоятельная промежуточная операция.

DoubleStream skip(long n)

Возвращает поток, состоящий из оставшихся элементов этого потока после отбрасывания первых n элементов потока. Если этот поток содержит меньше n элементов, то будет возвращен пустой поток.

Это состоятельное промежуточное действие.

default DoubleStream takeWhile(DoublePredicate predicate)

Возвращает, если этот поток упорядочен, поток, содержащий самую длинную префиксную последовательность элементов из этого потока, соответствующую заданному предикату. В противном случае, если этот поток неупорядочен, возвращает поток, содержащий подмножество элементов из этого потока, соответствующих заданному предикату.

Если этот поток упорядочен, то самая длинная префиксная последовательность — это непрерывная последовательность элементов из этого потока, соответствующая заданному предикату. Первый элемент последовательности — первый элемент этого потока, а элемент, непосредственно следующий за последним элементом последовательности, не соответствует заданному предикату.

Если этот поток неупорядочен и некоторые (но не все) элементы этого потока соответствуют заданному предикату, поведение этой операции является не детерминированным; он может выбрать любое подмножество соответствующих элементов (включая пустое множество).

Независимо от того, упорядочен ли этот поток или нет, если все элементы потока соответствуют заданному предикату, эта операция берет все элементы (результат совпадает с входом), или если ни один элемент потока не соответствует заданному предикату, то элементы не берутся (результат — пустой поток).

Это короткое, состоятельное промежуточное действие.

default DoubleStream dropWhile(DoublePredicate predicate)

Возвращает, если этот поток упорядочен, поток, состоящий из оставшихся элементов этого потока после удаления самой длинной префиксной последовательности элементов, соответствующих заданному предикату. В противном случае, если этот поток неупорядочен, возвращает поток, содержащий оставшиеся элементы потока после удаления подмножества элементов, соответствующих заданному предикату.

Если этот поток упорядочен, то самая длинная префиксная последовательность — это непрерывная последовательность элементов из этого потока, соответствующая заданному предикату. Первый элемент последовательности — первый элемент этого потока, а элемент, непосредственно следующий за последним элементом последовательности, не соответствует заданному предикату.

Если этот поток неупорядочен и некоторые (но не все) элементы этого потока соответствуют заданному предикату, поведение этой операции является не детерминированным; он может удалить любое подмножество соответствующих элементов (включая пустое множество).

Независимо от того, упорядочен ли этот поток или нет, если все элементы потока соответствуют заданному предикату, эта операция отбрасывает все элементы (результат — пустой поток), или если ни один элемент потока не соответствует заданному предикату, то элементы не отбрасываются (результат — такой же, как входной).

Это состоятельное промежуточное действие.

void forEach(DoubleConsumer action)

Выполняет действие для каждого элемента этого потока.

Это конечная операция.

Для параллельных потоков данных эта операция не гарантирует соблюдение порядка встречи элементов потока, так как это приведет к потере преимуществ параллелизма. Для любого данного элемента действие может быть выполнено в любое время и в любой потоке, выбранном библиотекой. Если действие обращается к общим данным, оно отвечает за предоставление необходимой синхронизации.

void forEachOrdered(DoubleConsumer action)

Выполняет действие для каждого элемента этого потока, гарантируя, что каждый элемент обрабатывается в порядке встречи для потоков, имеющих определенный порядок встречи.

Это конечная операция.

double[] toArray()

Возвращает массив, содержащий элементы этого потока.

Это конечная операция.

double reduce(double identity, DoubleBinaryOperator op)

Выполняет свертку элементов этого потока, используя предоставленное начальное значение и ассоциативную функцию накопления, и возвращает свернутое значение. Это эквивалентно:

     double result = identity;
     for (double element : this stream)
         result = accumulator.applyAsDouble(result, element)
     return result;
 

но не ограничено выполнением последовательно.

Значение identity должно быть тождеством для функции накопления. Это означает, что для всех x, accumulator.apply(identity, x) равно x. Функция accumulator должна быть ассоциативной функцией.

Это терминальная операция.

OptionalDouble reduce(DoubleBinaryOperator op)

Выполняет свертку элементов этого потока, используя ассоциативную функцию накопления, и возвращает OptionalDouble, описывающий свернутое значение, если таковое имеется. Это эквивалентно:

     boolean foundAny = false;
     double result = null;
     for (double element : this stream) {
         if (!foundAny) {
             foundAny = true;
             result = element;
         }
         else
             result = accumulator.applyAsDouble(result, element);
     }
     return foundAny ? OptionalDouble.of(result) : OptionalDouble.empty();
 

но не ограничено выполнением последовательно.

Функция accumulator должна быть ассоциативной функцией.

Это терминальная операция.

<R> R collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)

Выполняет операцию изменяемой свертки над элементами этого потока. Изменяемая свертка — это такая свертка, в которой свернутое значение является изменяемым контейнером результатов, например, ArrayList, а элементы включаются путем обновления состояния результата, а не путем замены результата. Это дает результат, эквивалентный:

     R result = supplier.get();
     for (double element : this stream)
         accumulator.accept(result, element);
     return result;
 

Как и reduce(double, DoubleBinaryOperator), операции collect могут быть распараллелены без необходимости дополнительной синхронизации.

Это терминальная операция.

double sum()

Возвращает сумму элементов в этом потоке. Суммирование является частным случаем свертки. Если суммирование с плавающей запятой было бы точным, этот метод был бы эквивалентен:

     return reduce(0, Double::sum);
 

Однако, поскольку суммирование с плавающей запятой не является точным, приведенный выше код не обязательно эквивалентен вычислению суммирования, выполняемому этим методом.

Значение суммы с плавающей запятой является функцией как входных значений, так и порядка операций сложения. Порядок операций сложения этого метода преднамеренно не определен, чтобы обеспечить гибкость реализации для повышения скорости и точности вычисляемого результата. В частности, этот метод может быть реализован с использованием компенсированного суммирования или другой техники для уменьшения границы погрешности в численной сумме по сравнению с простым суммированием значений double. Из-за неопределенного порядка операций и возможности использования различных схем суммирования вывод этого метода может варьироваться на одних и тех же входных элементах.

Различные условия могут привести к вычислению бесконечной суммы. Это может произойти даже в том случае, если все суммируемые элементы конечны. Если какой-либо элемент не является конечным, сумма будет бесконечной:

• Если какой-либо элемент является NaN, то конечная сумма будет NaN.
• Если элементы содержат одну или несколько бесконечностей, сумма будет бесконечной или NaN.
  • Если элементы содержат бесконечности противоположного знака, сумма будет NaN.
  • Если элементы содержат бесконечности одного знака, а промежуточная сумма переполняется до бесконечности противоположного знака, сумма может быть NaN.

Возможно, что промежуточные суммы конечных значений переполняются в бесконечности противоположного знака; если это произойдет, конечная сумма будет NaN, даже если все элементы конечны. Если все элементы равны нулю, знак нуля не гарантируется сохранение в конечной сумме.

Это терминальная операция.

OptionalDouble min()

Возвращает OptionalDouble, описывающий минимальный элемент этого потока, или пустой OptionalDouble, если этот поток пуст. Минимальный элемент будет Double.NaN, если любой элемент потока был NaN. В отличие от операторов численного сравнения, этот метод считает отрицательный ноль строго меньшим, чем положительный ноль. Это частный случай свертки и эквивалентно:

     return reduce(Double::min);
 

Это терминальная операция.

OptionalDouble max()

Возвращает OptionalDouble, описывающий максимальный элемент этого потока, или пустой OptionalDouble, если этот поток пуст. Максимальный элемент будет Double.NaN, если любой элемент потока был NaN. В отличие от операторов численного сравнения, этот метод считает отрицательный ноль строго меньшим, чем положительный ноль. Это частный случай свертки и эквивалентно:

     return reduce(Double::max);
 

Это терминальная операция.

long count()

Возвращает количество элементов в этом потоке. Это частный случай свертки и эквивалентно:

     return mapToLong(e -> 1L).sum();
 

Это терминальная операция.

OptionalDouble average()

Возвращает OptionalDouble, описывающий среднее арифметическое элементов этого потока, или пустой необязательный элемент, если этот поток пуст.

Вычисленное среднее значение может варьироваться численно и иметь специальное поведение, как при вычислении суммы; см. sum() для получения подробной информации.

Среднее значение является частным случаем свертки.

Это терминальная операция.

DoubleSummaryStatistics summaryStatistics()

Возвращает DoubleSummaryStatistics , описывающую различные сводные данные об элементах этого потока. Это частный случай редукции.

Это конечная операция.

boolean anyMatch(DoublePredicate predicate)

Возвращает значение, указывающее, совпадает ли какой-либо элемент этого потока с заданным предикатом. Может не вычислять предикат для всех элементов, если это не требуется для определения результата. Если поток пуст, возвращается false, и предикат не вычисляется.

Это короткозамкнутая конечная операция.

boolean allMatch(DoublePredicate predicate)

Возвращает значение, указывающее, соответствуют ли все элементы этого потока предоставленному предикату. Может не вычислять предикат для всех элементов, если это не требуется для определения результата. Если поток пуст, возвращается true, и предикат не вычисляется.

Это короткозамкнутая конечная операция.

boolean noneMatch(DoublePredicate predicate)

Возвращает значение, указывающее, не соответствуют ли никакие элементы этого потока предоставленному предикату. Может не вычислять предикат для всех элементов, если это не требуется для определения результата. Если поток пуст, возвращается true, и предикат не вычисляется.

Это короткозамкнутая конечная операция.

OptionalDouble findFirst()

Возвращает OptionalDouble, описывающую первый элемент этого потока, или пустой OptionalDouble , если поток пуст. Если у потока нет порядка встречи, может быть возвращён любой элемент.

Это короткозамкнутая конечная операция.

OptionalDouble findAny()

Возвращает OptionalDouble, описывающую какой-либо элемент потока, или пустой OptionalDouble , если поток пуст.

Поведение этой операции явно недетерминировано; она свободна выбрать любой элемент в потоке. Это позволяет обеспечить максимальную производительность в параллельных операциях; затраты заключаются в том, что несколько вызовов одного и того же источника могут не возвращать один и тот же результат. (Если требуется стабильный результат, используйте findFirst() вместо этого.)

Stream<Double> boxed()

Возвращает Stream , содержащий элементы этого потока, упакованные в Double.

Это промежуточная операция.

static DoubleStream.Builder builder()

Возвращает билдер для DoubleStream.

static DoubleStream empty()

Возвращает пустой последовательный DoubleStream.

static DoubleStream of(double t)

Возвращает последовательный DoubleStream , содержащий один элемент.

static DoubleStream of(double... values)

Возвращает упорядоченный последовательный поток, элементами которого являются указанные значения.

static DoubleStream iterate(double seed, DoubleUnaryOperator f)

Возвращает бесконечный упорядоченный последовательный DoubleStream , полученный итеративным применением функции f к начальному элементу seed, создавая Stream , состоящий из seed, f(seed), f(f(seed)) и т.д.

Первый элемент (позиция 0) в DoubleStream будет предоставленным seed. Для n > 0, элемент на позиции n, будет результатом применения функции f к элементу на позиции n - 1.

Действие применения f для одного элемента предшествует действию применения f для последующих элементов. Для любого заданного элемента действие может выполняться в любом потоке, который библиотека выбирает.

static DoubleStream iterate(double seed, DoublePredicate hasNext, DoubleUnaryOperator next)

Возвращает упорядоченный последовательный DoubleStream , полученный итеративным применением заданной функции next к начальному элементу, при условии выполнения заданного предиката hasNext. Поток завершается, как только предикат hasNext возвращает false.

DoubleStream.iterate должен генерировать ту же последовательность элементов, что и соответствующий цикл for:

     for (double index=seed; hasNext.test(index); index = next.applyAsDouble(index)) {
         ...
     }
 

Результат может быть пустым, если предикат hasNext не выполняется для начального значения. В противном случае первым элементом будет предоставленное значение seed, следующим (если есть) будет результат применения функции next к значению seed, и так далее итеративно, пока предикат hasNext не укажет, что поток должен завершиться.

Действие применения предиката hasNext к элементу предшествует действию применения функции next к этому элементу. Действие применения функции next для одного элемента предшествует действию применения предиката hasNext для последующих элементов. Для любого заданного элемента действие может выполняться в любом потоке, который выбирает библиотека.

static DoubleStream generate(DoubleSupplier s)

Возвращает бесконечный неупорядоченный последовательный поток, где каждый элемент генерируется предоставленным DoubleSupplier. Это подходит для генерации постоянных потоков, потоков случайных элементов и т. д.

static DoubleStream concat(DoubleStream a, DoubleStream b)

Создаёт лениво конкатенированный поток, элементы которого — все элементы первого потока, за которыми следуют все элементы второго потока. Результирующий поток упорядочен, если оба входных потока упорядочены, и параллелен, если хотя бы один из входных потоков параллелен. При закрытии результирующего потока вызываются обработчики закрытия для обоих входных потоков.

Этот метод работает с двумя входными потоками и связывает каждый поток с его источником. В результате последующие изменения источника входного потока могут не отражаться в результирующем конкатенированном потоке.