Интерфейс DoubleStream

DoubleStream filter(DoublePredicate predicate)

Параметры:

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

Возвращает:

новый поток

DoubleStream map(DoubleUnaryOperator mapper)

Параметры:

mapper — не взаимодействующая с другими данными, без состояния функция, применяемая к каждому элементу

Возвращает:

новый поток

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

Параметры типа:

U — тип элементов нового потока

Параметры:

mapper — не взаимодействующая с другими данными, без состояния функция, применяемая к каждому элементу

Возвращает:

новый поток

IntStream mapToInt(DoubleToIntFunction mapper)

Параметры:

mapper — не взаимодействующая с другими данными, без состояния функция, применяемая к каждому элементу

Возвращает:

новый поток

LongStream mapToLong(DoubleToLongFunction mapper)

Параметры:

mapper — не взаимодействующая с другими данными, без состояния функция, применяемая к каждому элементу

Возвращает:

новый поток

DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

Параметры:

mapper — не взаимодействующая с другими данными, без состояния функция, применяемая к каждому элементу и создающая DoubleStream новых значений

Возвращает:

новый поток

См. также:

• Stream.flatMap(Function)

default DoubleStream mapMulti(DoubleStream.DoubleMapMultiConsumer mapper)

Требования к реализации:

Реализация по умолчанию вызывает для этого потока flatMap, передавая функцию со следующим поведением. Сначала она вызывает функцию-отображение с DoubleConsumer, который накапливает элементы-замены во вновь созданном внутреннем буфере. После возврата функции-отображения она создает DoubleStream из внутреннего буфера. Затем она возвращает этот поток в flatMap.

Параметры:

mapper — не взаимодействующая с другими данными, без состояния функция, создающая элементы-замены

Возвращает:

новый поток

Начиная с версии:

16

См. также:

• Stream.mapMulti

DoubleStream distinct()

Возвращает:

результирующий поток

DoubleStream sorted()

Возвращает:

результирующий поток

DoubleStream peek(DoubleConsumer action)

Примечание API:

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

    DoubleStream.of(1, 2, 3, 4)
        .filter(e -> e > 2)
        .peek(e -> System.out.println("Filtered value: " + e))
        .map(e -> e * e)
        .peek(e -> System.out.println("Mapped value: " + e))
        .sum();

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

Параметры:

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

Возвращает:

новый поток

DoubleStream limit(long maxSize)

Примечание API:

Хотя limit() обычно является недорогой операцией в последовательных конвейерах потоков, в упорядоченных параллельных конвейерах она может быть довольно затратной, особенно при больших значениях maxSize, поскольку limit(n) должна возвращать не любые n элементов, а именно первые n элементов в порядке следования. Использование неупорядоченного источника потока (например, generate(DoubleSupplier)) или снятие ограничения порядка с помощью BaseStream.unordered() может значительно ускорить limit() в параллельных конвейерах, если это допускается семантикой вашей задачи. Если требуется сохранение порядка следования и наблюдается низкая производительность или чрезмерное использование памяти при выполнении limit() в параллельных конвейерах, переключение на последовательное выполнение с помощью BaseStream.sequential() может повысить производительность.

Параметры:

maxSize — количество элементов, до которого следует ограничить поток

Возвращает:

новый поток

Выбрасывает:

IllegalArgumentException — если maxSize отрицательно

DoubleStream skip(long n)

Примечание API:

Хотя skip() обычно является недорогой операцией в последовательных конвейерах потоков, в упорядоченных параллельных конвейерах она может быть довольно затратной, особенно при больших значениях n, поскольку skip(n) должна пропускать не любые n элементов, а именно первые n элементов в порядке следования. Использование неупорядоченного источника потока (например, generate(DoubleSupplier)) или снятие ограничения порядка с помощью BaseStream.unordered() может значительно ускорить skip() в параллельных конвейерах, если это допускается семантикой вашей задачи. Если требуется сохранение порядка следования и наблюдается низкая производительность или чрезмерное использование памяти при выполнении skip() в параллельных конвейерах, переключение на последовательное выполнение с помощью BaseStream.sequential() может повысить производительность.

Параметры:

n — количество начальных элементов, которые следует пропустить

Возвращает:

новый поток

Выбрасывает:

IllegalArgumentException — если n отрицательно

default DoubleStream takeWhile(DoublePredicate predicate)

Примечание API:

Хотя takeWhile() обычно является недорогой операцией в последовательных конвейерах потоков, в упорядоченных параллельных конвейерах она может быть довольно затратной, поскольку операция должна возвращать не любой допустимый начальный фрагмент, а самый длинный начальный фрагмент элементов в порядке следования. Использование неупорядоченного источника потока (например, generate(DoubleSupplier)) или снятие ограничения порядка с помощью BaseStream.unordered() может значительно ускорить takeWhile() в параллельных конвейерах, если это допускается семантикой вашей задачи. Если требуется сохранение порядка следования и наблюдается низкая производительность или чрезмерное использование памяти при выполнении takeWhile() в параллельных конвейерах, переключение на последовательное выполнение с помощью BaseStream.sequential() может повысить производительность.

Требования к реализации:

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

Параметры:

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

Возвращает:

новый поток

Начиная с версии:

9

default DoubleStream dropWhile(DoublePredicate predicate)

Примечание API:

Хотя dropWhile() обычно является недорогой операцией в последовательных конвейерах потоков, в упорядоченных параллельных конвейерах она может быть довольно затратной, поскольку операция должна возвращать не любой допустимый начальный фрагмент, а самый длинный начальный фрагмент элементов в порядке следования. Использование неупорядоченного источника потока (например, generate(DoubleSupplier)) или снятие ограничения порядка с помощью BaseStream.unordered() может значительно ускорить dropWhile() в параллельных конвейерах, если это допускается семантикой вашей задачи. Если требуется сохранение порядка следования и наблюдается низкая производительность или чрезмерное использование памяти при выполнении dropWhile() в параллельных конвейерах, переключение на последовательное выполнение с помощью BaseStream.sequential() может повысить производительность.

Требования к реализации:

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

Параметры:

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

Возвращает:

новый поток

Начиная с версии:

9

void forEach(DoubleConsumer action)

Параметры:

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

void forEachOrdered(DoubleConsumer action)

Параметры:

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

См. также:

• forEach(DoubleConsumer)

double[] toArray()

Возвращает:

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

double reduce(double identity, DoubleBinaryOperator op)

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

Примечание API:

Сумма, минимум, максимум и среднее — частные случаи свертки. Суммирование потока чисел можно выразить так:

    double sum = numbers.reduce(0, (a, b) -> a+b);

или, в более компактной форме:

    double sum = numbers.reduce(0, Double::sum);

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

Параметры:

identity — начальное значение для функции накопления

op — ассоциативная, не взаимодействующая с другими данными, без состояния функция для объединения двух значений

Возвращает:

результат свертки

См. также:

• sum()
• min()
• max()
• average()

OptionalDouble reduce(DoubleBinaryOperator op)

    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();

Параметры:

op — ассоциативная, не взаимодействующая с другими данными, без состояния функция для объединения двух значений

Возвращает:

результат свертки

См. также:

• reduce(double, DoubleBinaryOperator)

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

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

Параметры типа:

R — тип изменяемого контейнера результата

Параметры:

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

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

combiner — ассоциативная, не взаимодействующая с другими данными, без состояния функция, принимающая два частичных контейнера результата и объединяющая их; она должна быть совместима с функцией-аккумулятором. Функция-комбинатор должна добавлять элементы из второго контейнера результата в первый.

Возвращает:

результат свертки

См. также:

• Stream.collect(Supplier, BiConsumer, BiConsumer)

double sum()

    return reduce(0, Double::sum);

Примечание API:

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

Возвращает:

сумму элементов этого потока

OptionalDouble min()

    return reduce(Double::min);

Возвращает:

OptionalDouble, содержащий минимальный элемент этого потока, или пустой Optional, если поток пуст

OptionalDouble max()

    return reduce(Double::max);

Возвращает:

OptionalDouble, содержащий максимальный элемент этого потока, или пустой объект Optional, если поток пуст

long count()

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

Примечание к API:

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

    DoubleStream s = DoubleStream.of(1, 2, 3, 4);
    long count = s.peek(System.out::println).count();

Количество элементов, содержащихся в источнике потока, известно, а промежуточная операция peek не добавляет элементы в поток и не удаляет их из него (как это может происходить при операциях flatMap или filter). Поэтому количество равно 4, и выполнять конвейер нет необходимости; следовательно, элементы не будут выведены в качестве побочного эффекта.

Возвращает:

количество элементов в этом потоке

OptionalDouble average()

Примечание к API:

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

Возвращает:

OptionalDouble, содержащее среднее значение элементов этого потока, или пустой объект Optional, если поток пуст

DoubleSummaryStatistics summaryStatistics()

Возвращает:

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

boolean anyMatch(DoublePredicate predicate)

Примечание к API:

Этот метод вычисляет экзистенциальное квантифицирование предиката для элементов потока (для некоторого x P(x)).

Параметры:

predicate — не мешающий, без состояния предикат, применяемый к элементам этого потока

Возвращает:

true, если какой-либо элемент потока соответствует заданному предикату; в противном случае — false

boolean allMatch(DoublePredicate predicate)

Примечание к API:

Этот метод вычисляет универсальное квантифицирование предиката для элементов потока (для всех x P(x)). Если поток пуст, квантификация считается выполненной вакуумно и всегда возвращает true (независимо от P(x)).

Параметры:

predicate — не мешающий, без состояния предикат, применяемый к элементам этого потока

Возвращает:

true, если все элементы потока соответствуют заданному предикату или поток пуст; в противном случае — false

boolean noneMatch(DoublePredicate predicate)

Примечание к API:

Этот метод вычисляет универсальное квантифицирование отрицания предиката для элементов потока (для всех x ~P(x)). Если поток пуст, квантификация считается выполненной вакуумно и всегда возвращает true независимо от P(x).

Параметры:

predicate — не мешающий, без состояния предикат, применяемый к элементам этого потока

Возвращает:

true, если ни один элемент потока не соответствует заданному предикату или поток пуст; в противном случае — false

OptionalDouble findFirst()

Возвращает:

OptionalDouble, описывающий первый элемент этого потока, или пустой OptionalDouble, если поток пуст

OptionalDouble findAny()

Возвращает:

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

См. также:

• findFirst()

Stream<Double> boxed()

Возвращает:

Stream, состоящий из элементов этого потока, каждый из которых преобразован в объект-обертку Double

static DoubleStream.Builder builder()

Возвращает:

построитель потока

static DoubleStream empty()

Возвращает:

пустой последовательный поток

static DoubleStream of(double t)

Параметры:

t — единственный элемент

Возвращает:

последовательный поток из одного элемента

static DoubleStream of(double... values)

Параметры:

values — элементы нового потока

Возвращает:

новый поток

static DoubleStream iterate(double seed, DoubleUnaryOperator f)

Параметры:

seed — начальный элемент

f — функция, применяемая к предыдущему элементу для получения нового элемента

Возвращает:

новый последовательный DoubleStream

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

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

Параметры:

seed — начальный элемент

hasNext — предикат, применяемый к элементам для определения момента завершения потока

next — функция, применяемая к предыдущему элементу для получения нового элемента

Возвращает:

новый последовательный DoubleStream

С момента:

9

static DoubleStream generate(DoubleSupplier s)

Параметры:

s — DoubleSupplier для генерируемых элементов

Возвращает:

новый бесконечный последовательный неупорядоченный DoubleStream

static DoubleStream concat(DoubleStream a, DoubleStream b)

Примечание к API:

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

    DoubleStream concat = Stream.of(s1, s2, s3, s4).flatMapToDouble(s -> s);

Примечание по реализации:

Будьте осторожны при создании потоков путем многократной конкатенации. Доступ к элементу глубоко конкатенированного потока может привести к глубокой цепочке вызовов или даже к StackOverflowError.

Параметры:

a — первый поток

b — второй поток

Возвращает:

конкатенацию двух входных потоков