Интерфейс IntStream

IntStream filter(IntPredicate predicate)

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

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

IntStream map(IntUnaryOperator mapper)

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

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

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

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

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

LongStream mapToLong(IntToLongFunction mapper)

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

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

DoubleStream mapToDouble(IntToDoubleFunction mapper)

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

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

IntStream flatMap(IntFunction<? extends IntStream> mapper)

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

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

default IntStream mapMulti(IntStream.IntMapMultiConsumer mapper)

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

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

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

IntStream distinct()

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

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

IntStream sorted()

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

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

IntStream peek(IntConsumer action)

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

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

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

IntStream limit(long maxSize)

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

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

IntStream skip(long n)

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

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

default IntStream takeWhile(IntPredicate predicate)

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

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

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

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

Это короткозамыкающая состояниезависимая промежуточная операция.

default IntStream dropWhile(IntPredicate predicate)

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

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

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

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

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

void forEach(IntConsumer action)

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

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

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

void forEachOrdered(IntConsumer action)

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

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

int[] toArray()

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

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

int reduce(int identity, IntBinaryOperator op)

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

     int result = identity;
     for (int element : this stream)
         result = accumulator.applyAsInt(result, element)
     return result;
 

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

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

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

OptionalInt reduce(IntBinaryOperator op)

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

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

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

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

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

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

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

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

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

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

int sum()

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

     return reduce(0, Integer::sum);
 

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

OptionalInt min()

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

     return reduce(Integer::min);
 

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

OptionalInt max()

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

     return reduce(Integer::max);
 

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

long count()

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

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

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

OptionalDouble average()

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

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

IntSummaryStatistics summaryStatistics()

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

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

boolean anyMatch(IntPredicate predicate)

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

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

boolean allMatch(IntPredicate predicate)

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

Это краткосрочная заключительная операция.

boolean noneMatch(IntPredicate predicate)

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

Это краткосрочная заключительная операция.

OptionalInt findFirst()

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

Это краткосрочная заключительная операция.

OptionalInt findAny()

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

Это краткосрочная заключительная операция.

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

LongStream asLongStream()

Возвращает LongStream состоящий из элементов этого потока, преобразованных в long.

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

DoubleStream asDoubleStream()

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

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

Stream<Integer> boxed()

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

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

static IntStream.Builder builder()

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

static IntStream empty()

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

static IntStream of(int t)

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

static IntStream of(int... values)

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

static IntStream iterate(int seed, IntUnaryOperator f)

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

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

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

static IntStream iterate(int seed, IntPredicate hasNext, IntUnaryOperator next)

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

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

     for (int index=seed; hasNext.test(index); index = next.applyAsInt(index)) {
         ...
     }
 

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

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

static IntStream generate(IntSupplier s)

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

static IntStream range(int startInclusive, int endExclusive)

Возвращает упорядоченный последовательный IntStream от startInclusive (включительно) до endExclusive (исключительно) с шагом увеличения 1.

static IntStream rangeClosed(int startInclusive, int endInclusive)

Возвращает последовательный упорядоченный IntStream от startInclusive (включительно) до endInclusive (включительно) с шагом нарастания 1.

static IntStream concat(IntStream a, IntStream b)

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

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