Spec-Zone .ru
спецификации, руководства, описания, API
|
Конструктор и Описание |
---|
DelegatingStream(Stream<T> delegate)
Создайте a
Stream это делегирует операции другому Stream . |
Модификатор и Тип | Метод и Описание |
---|---|
boolean |
allMatch(Predicate<? super T> predicate)
Возвраты, соответствуют ли все элементы этого потока обеспеченный предикат.
|
boolean |
anyMatch(Predicate<? super T> predicate)
Возвраты, соответствуют ли какие-либо элементы этого потока обеспеченный предикат.
|
<R> R |
collect(Collector<? super T,R> collector)
Выполняет изменчивую работу сокращения на элементах этого потока, используя a
Collector объект описать сокращение. |
<R> R |
collect(Supplier<R> resultFactory, BiConsumer<R,? super T> accumulator, BiConsumer<R,R> combiner)
Выполняет изменчивую работу сокращения на элементах этого потока.
|
long |
count()
Возвращает количество элементов в этом потоке.
|
Stream<T> |
distinct()
Возвращает поток, состоящий из отличных элементов (согласно
Object.equals(Object) ) из этого потока. |
Stream<T> |
filter(Predicate<? super T> predicate)
Возвращает поток, состоящий из элементов этого потока, которые соответствуют данный предикат.
|
Optional<T> |
findAny()
Возвраты
Optional описание некоторого элемента потока, или пустого Optional если поток пуст. |
Optional<T> |
findFirst()
Возвраты
Optional описание первого элемента этого потока (во встретиться порядке), или пустое Optional если поток пуст. |
<R> Stream<R> |
flatMap(Function<? super T,? extends Stream<? extends R>> mapper)
Возвращает поток, состоящий из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченную функцию отображения к каждому элементу.
|
DoubleStream |
flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)
Возвраты a
DoubleStream состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. |
IntStream |
flatMapToInt(Function<? super T,? extends IntStream> mapper)
Возвраты
IntStream состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. |
LongStream |
flatMapToLong(Function<? super T,? extends LongStream> mapper)
Возвраты a
LongStream состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. |
void |
forEach(Consumer<? super T> action)
Выполняет действие для каждого элемента этого потока.
|
void |
forEachOrdered(Consumer<? super T> action)
Выполняет действие для каждого элемента этого потока, гарантируя, что каждый элемент обрабатывается в, встречаются с порядком на потоки, у которых есть определенный, встречаются с порядком.
|
boolean |
isParallel()
Возвраты, выполнился ли бы этот поток, когда выполняющийся, параллельно (не принимающий дальнейшей модификации потока, такого как добавление дальнейших промежуточных операций или изменение его параллелизма).
|
Iterator<T> |
iterator()
Возвращает iterator для элементов этого потока.
|
Stream<T> |
limit(long maxSize)
Возвращает поток, состоящий из элементов этого потока, усеченного, чтобы не быть больше чем
maxSize в длине. |
<R> Stream<R> |
map(Function<? super T,? extends R> mapper)
Возвращает поток, состоящий из результатов применения заданной функции к элементам этого потока.
|
DoubleStream |
mapToDouble(ToDoubleFunction<? super T> mapper)
Возвраты a
DoubleStream состоя из результатов применения заданной функции к элементам этого потока. |
IntStream |
mapToInt(ToIntFunction<? super T> mapper)
Возвраты
IntStream состоя из результатов применения заданной функции к элементам этого потока. |
LongStream |
mapToLong(ToLongFunction<? super T> mapper)
Возвраты a
LongStream состоя из результатов применения заданной функции к элементам этого потока. |
Optional<T> |
max(Comparator<? super T> comparator)
Возвращает максимальный элемент этого потока согласно обеспеченному
Comparator . |
Optional<T> |
min(Comparator<? super T> comparator)
Возвращает минимальный элемент этого потока согласно обеспеченному
Comparator . |
boolean |
noneMatch(Predicate<? super T> predicate)
Возвраты, не соответствуют ли никакие элементы этого потока обеспеченный предикат.
|
Stream<T> |
parallel()
Возвращает эквивалентный поток, который параллелен.
|
Stream<T> |
peek(Consumer<? super T> consumer)
Возвращает поток, состоящий из элементов этого потока, дополнительно выполняя обеспеченное действие на каждом элементе, поскольку элементы используются от получающегося потока.
|
Optional<T> |
reduce(BinaryOperator<T> accumulator)
Выполняет сокращение на элементах этого потока, используя ассоциативную функцию накопления, и возвращается
Optional описание уменьшенного значения, если любой. |
T |
reduce(T identity, BinaryOperator<T> accumulator)
Выполняет сокращение на элементах этого потока, используя обеспеченное значение идентификационных данных и ассоциативную функцию накопления, и возвращает уменьшенное значение.
|
<U> U |
reduce(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner)
Выполняет сокращение на элементах этого потока, используя обеспеченные идентификационные данные, функцию накопления, и объединяющиеся функции.
|
Stream<T> |
sequential()
Возвращает эквивалентный поток, который последователен.
|
Stream<T> |
sorted()
Возвращает поток, состоящий из элементов этого потока, сортированного согласно естественному порядку.
|
Stream<T> |
sorted(Comparator<? super T> comparator)
Возвращает поток, состоящий из элементов этого потока, сортированного согласно обеспеченному
Comparator . |
Spliterator<T> |
spliterator()
Возвращает spliterator для элементов этого потока.
|
Stream<T> |
substream(long startingOffset)
Возвращает поток, состоящий из остающихся элементов этого потока после индексации
startInclusive элементы в поток. |
Stream<T> |
substream(long startingOffset, long endingOffset)
Возвращает поток, состоящий из остающихся элементов этого потока после индексации
startInclusive элементы в поток и усеченный, чтобы содержать не больше, чем endExclusive - startInclusive элементы. |
Объект[] |
toArray()
Возвращает массив, содержащий элементы этого потока.
|
<A> A[] |
toArray(IntFunction<A[]> generator)
Возвращает массив, содержащий элементы этого потока, используя обеспеченный
generator функция, чтобы выделить возвращенный массив. |
Stream<T> |
unordered()
Возвращает эквивалентный поток, который неупорядочивается.
|
public DelegatingStream(Stream<T> delegate)
Stream
это делегирует операции другому Stream
.delegate
- базовое Stream
к которому мы делегируем все Stream
методыNullPointerException
- если делегат является нулемpublic Spliterator<T> spliterator()
Это - терминальная работа.
public boolean isParallel()
true
если этот поток выполнился бы параллельно если выполняющийся без дальнейшей модификации иначе false
public Iterator<T> iterator()
Это - терминальная работа.
public Stream<T> filter(Predicate<? super T> predicate)
Stream
Это - промежуточная работа.
filter
в интерфейсе Stream<T>
predicate
- невмешательство, предикат не сохраняющий состояние, чтобы примениться к каждому элементу, чтобы определить, должно ли это быть включеноpublic <R> Stream<R> map(Function<? super T,? extends R> mapper)
Stream
Это - промежуточная работа.
map
в интерфейсе Stream<T>
R
- Тип элемента нового потокаmapper
- невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементуpublic IntStream mapToInt(ToIntFunction<? super T> mapper)
Stream
IntStream
состоя из результатов применения заданной функции к элементам этого потока. Это - промежуточная работа.
mapToInt
в интерфейсе Stream<T>
mapper
- невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементуpublic LongStream mapToLong(ToLongFunction<? super T> mapper)
Stream
LongStream
состоя из результатов применения заданной функции к элементам этого потока. Это - промежуточная работа.
mapToLong
в интерфейсе Stream<T>
mapper
- невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементуpublic DoubleStream mapToDouble(ToDoubleFunction<? super T> mapper)
Stream
DoubleStream
состоя из результатов применения заданной функции к элементам этого потока. Это - промежуточная работа.
mapToDouble
в интерфейсе Stream<T>
mapper
- невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементуpublic <R> Stream<R> flatMap(Function<? super T,? extends Stream<? extends R>> mapper)
Stream
null
, это обрабатывается, как будто результатом является пустой поток. Это - промежуточная работа.
flatMap
в интерфейсе Stream<T>
R
- Тип элемента нового потокаmapper
- невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементу, который производит поток новых значенийpublic IntStream flatMapToInt(Function<? super T,? extends IntStream> mapper)
Stream
IntStream
состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. Если результат отображающейся функции null
, это обрабатывается, как будто результатом является пустой поток. Это - промежуточная работа.
flatMapToInt
в интерфейсе Stream<T>
mapper
- невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементу, который производит поток новых значенийpublic LongStream flatMapToLong(Function<? super T,? extends LongStream> mapper)
Stream
LongStream
состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. Если результат отображающейся функции null
, это обрабатывается, как будто результатом является пустой поток. Это - промежуточная работа.
flatMapToLong
в интерфейсе Stream<T>
mapper
- невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементу, который производит поток новых значенийpublic DoubleStream flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)
Stream
DoubleStream
состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. Если результат отображающейся функции null
, это обрабатывается, как будто результатом является пустой поток. Это - промежуточная работа.
flatMapToDouble
в интерфейсе Stream<T>
mapper
- невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементу, который производит поток новых значенийpublic Stream<T> distinct()
Stream
Object.equals(Object)
) из этого потока. public Stream<T> sorted()
Stream
Comparable
, a java.lang.ClassCastException
может быть брошен, когда потоковый конвейер выполняется. public Stream<T> sorted(Comparator<? super T> comparator)
Stream
Comparator
. sorted
в интерфейсе Stream<T>
comparator
- невмешательство, не сохраняющее состояние Comparator
использоваться, чтобы сравнить потоковые элементыpublic void forEach(Consumer<? super T> action)
Stream
Это - терминальная работа.
Для параллельных потоковых конвейеров эта работа не гарантирует, что уважала встретиться порядок потока, поскольку выполнение так пожертвовало бы преимуществом параллелизма. Для любого данного элемента действие может быть выполнено в любое время, и в любом потоке выбирает библиотека. Если общее состояние доступов действия, это ответственно за обеспечение необходимой синхронизации.
forEach
в интерфейсе Stream<T>
action
- невмешивающееся действие, чтобы выполнить на элементахpublic void forEachOrdered(Consumer<? super T> action)
Stream
Это - терминальная работа.
forEachOrdered
в интерфейсе Stream<T>
action
- невмешивающееся действие, чтобы выполнить на элементахStream.forEach(Consumer)
public Stream<T> peek(Consumer<? super T> consumer)
Stream
Это - промежуточная работа.
Для параллельных потоковых конвейеров действие можно вызвать в любое время, и в любом потоке элемент делается доступным восходящей работой. Если действие изменяет общее состояние, это ответственно за обеспечение необходимой синхронизации.
peek
в интерфейсе Stream<T>
consumer
- невмешивающееся действие, чтобы выполнить на элементах, поскольку они используются от потокаpublic Stream<T> limit(long maxSize)
Stream
maxSize
в длине. public Stream<T> substream(long startingOffset)
Stream
startInclusive
элементы в поток. Если startInclusive
индексируйте находится мимо конца этого потока тогда будет возвращен, пустой поток. public Stream<T> substream(long startingOffset, long endingOffset)
Stream
startInclusive
элементы в поток и усеченный, чтобы содержать не больше, чем endExclusive - startInclusive
элементы. Если startInclusive
индексируйте находится мимо конца этого потока тогда будет возвращен, пустой поток. public <A> A[] toArray(IntFunction<A[]> generator)
Stream
generator
функция, чтобы выделить возвращенный массив. Это - терминальная работа.
public Object[] toArray()
Stream
Это - терминальная работа.
public T reduce(T identity, BinaryOperator<T> accumulator)
Stream
T result = identity;
for (T element : this stream)
result = accumulator.apply(result, element)
return result;
но не ограничивается выполниться последовательно. identity
значение должно быть идентификационными данными для функции аккумулятора. Это означает это для всех t
, accumulator.apply(identity, t)
равно t
. accumulator
функция должна быть ассоциативной функцией.
Это - терминальная работа.
reduce
в интерфейсе Stream<T>
identity
- значение идентификационных данных для накапливающейся функцииaccumulator
- ассоциативный
невмешательство, не сохраняющее состояние функционирует для того, чтобы объединить два значенияpublic Optional<T> reduce(BinaryOperator<T> accumulator)
Stream
Optional
описание уменьшенного значения, если любой. Это эквивалентно:
boolean foundAny = false;
T result = null;
for (T element : this stream) {
if (!foundAny) {
foundAny = true;
result = element;
}
else
result = accumulator.apply(result, element);
}
return foundAny ? Optional.of(result) : Optional.empty();
но не ограничивается выполниться последовательно. accumulator
функция должна быть ассоциативной функцией.
Это - терминальная работа.
reduce
в интерфейсе Stream<T>
accumulator
- ассоциативный
невмешательство, не сохраняющее состояние функционирует для того, чтобы объединить два значенияStream.reduce(Object, BinaryOperator)
, Stream.min(java.util.Comparator)
, Stream.max(java.util.Comparator)
public <U> U reduce(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner)
Stream
U result = identity;
for (T element : this stream)
result = accumulator.apply(result, element)
return result;
но не ограничивается выполниться последовательно. identity
значение должно быть идентификационными данными для функции объединителя. Это означает это для всех u
, combiner(identity, u)
равно u
. Дополнительно, combiner
функция должна быть совместимой с accumulator
функция; для всех u
и t
, следующее должно содержать:
combiner.apply(u, accumulator.apply(identity, t)) == accumulator.apply(u, t)
Это - терминальная работа.
reduce
в интерфейсе Stream<T>
U
- Тип результатаidentity
- значение идентификационных данных для функции объединителяaccumulator
- ассоциативный
невмешательство, не сохраняющее состояние функционирует для того, чтобы включить дополнительный элемент в результатcombiner
- ассоциативный
невмешательство, не сохраняющее состояние функционирует для того, чтобы объединить два значения, которые должны быть совместимыми с функцией аккумулятораStream.reduce(BinaryOperator)
, Stream.reduce(Object, BinaryOperator)
public <R> R collect(Supplier<R> resultFactory, BiConsumer<R,? super T> accumulator, BiConsumer<R,R> combiner)
Stream
ArrayList
, и элементы включаются, обновляя состояние результата, а не заменяя результат. Это приводит к результату, эквивалентному:
R result = resultFactory.get();
for (T element : this stream)
accumulator.accept(result, element);
return result;
Как Stream.reduce(Object, BinaryOperator)
, collect
операции могут быть параллелизированы, не требуя дополнительной синхронизации.
Это - терминальная работа.
collect
в интерфейсе Stream<T>
R
- тип результатаresultFactory
- функция, которая создает новый контейнер результата. Для параллельного выполнения эта функция может быть вызвана многократно и должна возвратить новое значение каждый раз.accumulator
- ассоциативный
невмешательство, не сохраняющее состояние функционирует для того, чтобы включить дополнительный элемент в результатcombiner
- ассоциативный
невмешательство, не сохраняющее состояние функционирует для того, чтобы объединить два значения, которые должны быть совместимыми с функцией аккумулятораpublic <R> R collect(Collector<? super T,R> collector)
Stream
Collector
объект описать сокращение. A Collector
инкапсулирует функции, используемые в качестве параметров Stream.collect(Supplier, BiConsumer, BiConsumer)
, учет повторного использования стратегий набора, и состава собирает операции, такие как многоуровневая группировка или разделение. Это - терминальная работа.
Когда выполняющийся параллельно, многократные промежуточные результаты можно инстанцировать, заполнили, и объединились, чтобы поддержать изоляцию изменчивых структур данных. Поэтому, даже когда выполняющийся параллельно с неориентированными на многопотоковое исполнение структурами данных (такой как ArrayList
), никакая дополнительная синхронизация не необходима для параллельного сокращения.
collect
в интерфейсе Stream<T>
R
- тип результатаcollector
- Collector
описание сокращенияStream.collect(Supplier, BiConsumer, BiConsumer)
, Collectors
public Optional<T> max(Comparator<? super T> comparator)
Stream
Comparator
. Это - особый случай сокращения. Это - терминальная работа.
max
в интерфейсе Stream<T>
comparator
- невмешательство, не сохраняющее состояние Comparator
использовать, чтобы сравнить элементы этого потокаOptional
описание максимального элемента этого потока, или пустого Optional
если поток пустpublic Optional<T> min(Comparator<? super T> comparator)
Stream
Comparator
. Это - особый случай сокращения. Это - терминальная работа.
min
в интерфейсе Stream<T>
comparator
- невмешательство, не сохраняющее состояние Comparator
использовать, чтобы сравнить элементы этого потокаOptional
описание минимального элемента этого потока, или пустого Optional
если поток пустpublic long count()
Stream
return mapToLong(e -> 1L).sum();
Это - терминальная работа.
public boolean anyMatch(Predicate<? super T> predicate)
Stream
anyMatch
в интерфейсе Stream<T>
predicate
- невмешательство, предикат не сохраняющий состояние, чтобы примениться к элементам этого потокаtrue
если какие-либо элементы потока соответствуют обеспеченный предикат иначе false
public boolean allMatch(Predicate<? super T> predicate)
Stream
allMatch
в интерфейсе Stream<T>
predicate
- невмешательство, предикат не сохраняющий состояние, чтобы примениться к элементам этого потокаtrue
если все элементы потока соответствуют обеспеченный предикат иначе false
public boolean noneMatch(Predicate<? super T> predicate)
Stream
noneMatch
в интерфейсе Stream<T>
predicate
- невмешательство, предикат не сохраняющий состояние, чтобы примениться к элементам этого потокаtrue
если никакие элементы потока не соответствуют обеспеченный предикат иначе false
public Optional<T> findFirst()
Stream
Optional
описание первого элемента этого потока (во встретиться порядке), или пустое Optional
если поток пуст. Если поток имеет, не встречаются с порядком, чем любой элемент может быть возвращен. public Optional<T> findAny()
Stream
Optional
описание некоторого элемента потока, или пустого Optional
если поток пуст. Это - закорачивающая терминальная работа.
Поведение этой работы явно недетерминировано; это свободно выбрать любой элемент в потоке. Это должно учесть максимальную производительность в параллельных операциях; стоимость - то, что многократные вызовы на том же самом источнике, возможно, не возвращают тот же самый результат. (Если первый элемент во встретиться порядке требуется, использовать Stream.findFirst()
вместо этого.)
findAny
в интерфейсе Stream<T>
Optional
описание некоторого элемента этого потока, или пустого Optional
если поток пустStream.findFirst()
public Stream<T> unordered()
Это - промежуточная работа.
public Stream<T> sequential()
Это - промежуточная работа.
public Stream<T> parallel()
Это - промежуточная работа.
Для дальнейшей ссылки API и документации разработчика, см. Java Документация SE. Та документация содержит более подробные, предназначенные разработчиком описания, с концептуальными краткими обзорами, определениями сроков, обходных решений, и рабочих примеров кода.
Авторское право © 1993, 2013, Oracle и/или его филиалы. Все права защищены.
Проект сборка-b92