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

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

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

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

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

     return reduce(Long::min);
 

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

OptionalLong max()

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

     return reduce(Long::max);
 

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

long count()

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

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

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

OptionalDouble average()

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

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

LongSummaryStatistics summaryStatistics()

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

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

boolean anyMatch(LongPredicate predicate)

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

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

boolean allMatch(LongPredicate predicate)

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

Это короткое конечное действие.

boolean noneMatch(LongPredicate predicate)

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

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

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