Интерфейс 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, описывающий среднее арифметическое элементов этого потока, или пустой Optional, если этот поток пуст.

Вычисленное среднее значение может численно отличаться и иметь специальное поведение, как при вычислении суммы; см. 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)

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

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