Интерфейс LongStream

LongStream filter(LongPredicate predicate)

Параметры:

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

Возвращает:

новый поток

LongStream map(LongUnaryOperator mapper)

Параметры:

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

Возвращает:

новый поток

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

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

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

Параметры:

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

Возвращает:

новый поток

IntStream mapToInt(LongToIntFunction mapper)

Параметры:

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

Возвращает:

новый поток

DoubleStream mapToDouble(LongToDoubleFunction mapper)

Параметры:

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

Возвращает:

новый поток

LongStream flatMap(LongFunction<? extends LongStream> mapper)

Параметры:

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

Возвращает:

новый поток

См. также:

• Stream.flatMap(Function)

default LongStream mapMulti(LongStream.LongMapMultiConsumer mapper)

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

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

Параметры:

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

Возвращает:

новый поток

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

16

См. также:

• Stream.mapMulti

LongStream distinct()

Возвращает:

новый поток

LongStream sorted()

Возвращает:

новый поток

LongStream peek(LongConsumer action)

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

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

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

Возвращает:

новый поток

LongStream limit(long maxSize)

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

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

Параметры:

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

Возвращает:

новый поток

Исключения:

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

LongStream skip(long n)

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

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

Параметры:

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

Возвращает:

новый поток

Исключения:

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

default LongStream takeWhile(LongPredicate predicate)

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

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

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

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

Параметры:

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

Возвращает:

новый поток

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

9

default LongStream dropWhile(LongPredicate predicate)

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

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

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

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

Параметры:

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

Возвращает:

новый поток

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

9

void forEach(LongConsumer action)

Параметры:

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

void forEachOrdered(LongConsumer action)

Параметры:

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

См. также:

• forEach(LongConsumer)

long[] toArray()

Возвращает:

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

long reduce(long identity, LongBinaryOperator op)

    long result = identity;
    for (long element : this stream)
        result = accumulator.applyAsLong(result, element)
    return result;

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

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

    long sum = integers.reduce(0, (a, b) -> a+b);

или более кратко:

    long sum = integers.reduce(0, Long::sum);

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

Параметры:

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

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

Возвращает:

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

См. также:

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

OptionalLong reduce(LongBinaryOperator op)

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

Параметры:

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

Возвращает:

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

См. также:

• reduce(long, LongBinaryOperator)

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

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

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

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

Параметры:

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

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

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

Возвращает:

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

См. также:

• Stream.collect(Supplier, BiConsumer, BiConsumer)

long sum()

    return reduce(0, Long::sum);

Возвращает:

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

OptionalLong min()

    return reduce(Long::min);

Возвращает:

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

OptionalLong max()

    return reduce(Long::max);

Возвращает:

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

long count()

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

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

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

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

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

Возвращает:

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

OptionalDouble average()

Возвращает:

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

LongSummaryStatistics summaryStatistics()

Возвращает:

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

boolean anyMatch(LongPredicate predicate)

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

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

Параметры:

predicate — предикат, применяемый к элементам этого потока, который не влияет на источник данных и не сохраняет состояние

Возвращает:

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

boolean allMatch(LongPredicate predicate)

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

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

Параметры:

predicate — предикат, применяемый к элементам этого потока, который не влияет на источник данных и не сохраняет состояние

Возвращает:

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

boolean noneMatch(LongPredicate predicate)

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

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

Параметры:

predicate — предикат, применяемый к элементам этого потока, который не влияет на источник данных и не сохраняет состояние

Возвращает:

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

OptionalLong findFirst()

Возвращает:

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

OptionalLong findAny()

Возвращает:

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

См. также:

• findFirst()

DoubleStream asDoubleStream()

Возвращает:

DoubleStream, состоящий из элементов этого потока, преобразованных в double

Stream<Long> boxed()

Возвращает:

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

static LongStream.Builder builder()

Возвращает:

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

static LongStream empty()

Возвращает:

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

static LongStream of(long t)

Параметры:

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

Возвращает:

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

static LongStream of(long... values)

Параметры:

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

Возвращает:

новый поток

static LongStream iterate(long seed, LongUnaryOperator f)

Параметры:

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

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

Возвращает:

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

static LongStream iterate(long seed, LongPredicate hasNext, LongUnaryOperator next)

    for (long index=seed; hasNext.test(index); index = next.applyAsLong(index)) {
        ...
    }

Параметры:

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

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

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

Возвращает:

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

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

9

static LongStream generate(LongSupplier s)

Параметры:

s — LongSupplier для создаваемых элементов

Возвращает:

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

static LongStream range(long startInclusive, long endExclusive)

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

Эквивалентную последовательность возрастающих значений можно получить последовательно с помощью цикла for следующим образом:

    for (long i = startInclusive; i < endExclusive ; i++) { ... }

Параметры:

startInclusive — начальное значение (включительно)

endExclusive — исключительная верхняя граница

Возвращает:

последовательный LongStream для диапазона из long элементов

static LongStream rangeClosed(long startInclusive, long endInclusive)

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

Эквивалентную последовательность возрастающих значений можно получить последовательно с помощью цикла for следующим образом:

    for (long i = startInclusive; i <= endInclusive ; i++) { ... }

Параметры:

startInclusive — начальное значение (включительно)

endInclusive — включительная верхняя граница

Возвращает:

последовательный LongStream для диапазона из long элементов

static LongStream concat(LongStream a, LongStream b)

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

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

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

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

Будьте осторожны при создании потоков путём многократного объединения. Обращение к элементу глубоко объединённого потока может привести к длинным цепочкам вызовов или даже к StackOverflowError.

Параметры:

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

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

Возвращает:

объединение двух входных потоков