Интерфейс LongStream

LongStream filter(LongPredicate predicate)

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

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

LongStream map(LongUnaryOperator mapper)

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

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

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

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

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

IntStream mapToInt(LongToIntFunction mapper)

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

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

DoubleStream mapToDouble(LongToDoubleFunction mapper)

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

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

LongStream flatMap(LongFunction<? extends LongStream> mapper)

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

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

default LongStream mapMulti(LongStream.LongMapMultiConsumer mapper)

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

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

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

LongStream distinct()

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

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

LongStream sorted()

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

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

LongStream peek(LongConsumer action)

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

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

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

LongStream limit(long maxSize)

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

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

LongStream skip(long n)

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

Это состоятельное промежуточное действие.

default LongStream takeWhile(LongPredicate predicate)

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

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

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

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

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

default LongStream dropWhile(LongPredicate predicate)

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

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

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

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

Это состоятельное промежуточное действие.

void forEach(LongConsumer action)

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

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

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

void forEachOrdered(LongConsumer action)

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

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

long[] toArray()

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

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

long reduce(long identity, LongBinaryOperator op)

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

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

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

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

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

OptionalLong reduce(LongBinaryOperator op)

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

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

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

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

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

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

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

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

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

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

long sum()

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

     return reduce(0, Long::sum);
 

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

OptionalLong min()

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

     return reduce(Long::min);
 

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

OptionalLong max()

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

     return reduce(Long::max);
 

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

long count()

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

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

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

OptionalDouble average()

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

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

LongSummaryStatistics summaryStatistics()

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

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

boolean anyMatch(LongPredicate predicate)

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

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

boolean allMatch(LongPredicate predicate)

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

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

boolean noneMatch(LongPredicate predicate)

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

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

OptionalLong findFirst()

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

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

OptionalLong findAny()

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

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

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

DoubleStream asDoubleStream()

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

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

Stream<Long> boxed()

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

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

static LongStream.Builder builder()

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

static LongStream empty()

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

static LongStream of(long t)

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

static LongStream of(long... values)

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

static LongStream iterate(long seed, LongUnaryOperator f)

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

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

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

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

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

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

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

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

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

static LongStream generate(LongSupplier s)

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

static LongStream range(long startInclusive, long endExclusive)

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

static LongStream rangeClosed(long startInclusive, long endInclusive)

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

static LongStream concat(LongStream a, LongStream b)

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

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