Интерфейс 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)

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

     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 , описывающую максимальный элемент этого потока, или пустой OptionalInt , если этот поток пуст. Это частный случай сокращения и эквивалентно:

     return reduce(Integer::max);
 

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

long count()

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

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

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

OptionalDouble average()

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

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

IntSummaryStatistics summaryStatistics()

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

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

boolean anyMatch(IntPredicate predicate)

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

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

boolean allMatch(IntPredicate predicate)

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

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

boolean noneMatch(IntPredicate predicate)

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

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

static IntStream concat(IntStream a, IntStream b)

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

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