|
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 если этот поток выполнился бы параллельно если выполняющийся без дальнейшей модификации иначе falsepublic 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)
StreamIntStream состоя из результатов применения заданной функции к элементам этого потока. Это - промежуточная работа.
mapToInt в интерфейсе Stream<T>mapper - невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементуpublic LongStream mapToLong(ToLongFunction<? super T> mapper)
StreamLongStream состоя из результатов применения заданной функции к элементам этого потока. Это - промежуточная работа.
mapToLong в интерфейсе Stream<T>mapper - невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементуpublic DoubleStream mapToDouble(ToDoubleFunction<? super T> mapper)
StreamDoubleStream состоя из результатов применения заданной функции к элементам этого потока. Это - промежуточная работа.
mapToDouble в интерфейсе Stream<T>mapper - невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементуpublic <R> Stream<R> flatMap(Function<? super T,? extends Stream<? extends R>> mapper)
Streamnull, это обрабатывается, как будто результатом является пустой поток. Это - промежуточная работа.
flatMap в интерфейсе Stream<T>R - Тип элемента нового потокаmapper - невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементу, который производит поток новых значенийpublic IntStream flatMapToInt(Function<? super T,? extends IntStream> mapper)
StreamIntStream состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. Если результат отображающейся функции null, это обрабатывается, как будто результатом является пустой поток. Это - промежуточная работа.
flatMapToInt в интерфейсе Stream<T>mapper - невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементу, который производит поток новых значенийpublic LongStream flatMapToLong(Function<? super T,? extends LongStream> mapper)
StreamLongStream состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. Если результат отображающейся функции null, это обрабатывается, как будто результатом является пустой поток. Это - промежуточная работа.
flatMapToLong в интерфейсе Stream<T>mapper - невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементу, который производит поток новых значенийpublic DoubleStream flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)
StreamDoubleStream состоя из результатов замены каждого элемента этого потока с содержанием потока, произведенного, применяя обеспеченное отображение, функционирует к каждому элементу. Если результат отображающейся функции null, это обрабатывается, как будто результатом является пустой поток. Это - промежуточная работа.
flatMapToDouble в интерфейсе Stream<T>mapper - невмешательство, функция не сохраняющая состояние, чтобы примениться к каждому элементу, который производит поток новых значенийpublic Stream<T> distinct()
StreamObject.equals(Object)) из этого потока. public Stream<T> sorted()
StreamComparable, a java.lang.ClassCastException может быть брошен, когда потоковый конвейер выполняется. public Stream<T> sorted(Comparator<? super T> comparator)
StreamComparator. 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)
StreammaxSize в длине. public Stream<T> substream(long startingOffset)
StreamstartInclusive элементы в поток. Если startInclusive индексируйте находится мимо конца этого потока тогда будет возвращен, пустой поток. public Stream<T> substream(long startingOffset, long endingOffset)
StreamstartInclusive элементы в поток и усеченный, чтобы содержать не больше, чем endExclusive - startInclusive элементы. Если startInclusive индексируйте находится мимо конца этого потока тогда будет возвращен, пустой поток. public <A> A[] toArray(IntFunction<A[]> generator)
Streamgenerator функция, чтобы выделить возвращенный массив. Это - терминальная работа.
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)
StreamOptional описание уменьшенного значения, если любой. Это эквивалентно:
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)
StreamArrayList, и элементы включаются, обновляя состояние результата, а не заменяя результат. Это приводит к результату, эквивалентному:
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)
StreamCollector объект описать сокращение. A Collector инкапсулирует функции, используемые в качестве параметров Stream.collect(Supplier, BiConsumer, BiConsumer), учет повторного использования стратегий набора, и состава собирает операции, такие как многоуровневая группировка или разделение. Это - терминальная работа.
Когда выполняющийся параллельно, многократные промежуточные результаты можно инстанцировать, заполнили, и объединились, чтобы поддержать изоляцию изменчивых структур данных. Поэтому, даже когда выполняющийся параллельно с неориентированными на многопотоковое исполнение структурами данных (такой как ArrayList), никакая дополнительная синхронизация не необходима для параллельного сокращения.
collect в интерфейсе Stream<T>R - тип результатаcollector - Collector описание сокращенияStream.collect(Supplier, BiConsumer, BiConsumer), Collectorspublic Optional<T> max(Comparator<? super T> comparator)
StreamComparator. Это - особый случай сокращения. Это - терминальная работа.
max в интерфейсе Stream<T>comparator - невмешательство, не сохраняющее состояние Comparator использовать, чтобы сравнить элементы этого потокаOptional описание максимального элемента этого потока, или пустого Optional если поток пустpublic Optional<T> min(Comparator<? super T> comparator)
StreamComparator. Это - особый случай сокращения. Это - терминальная работа.
min в интерфейсе Stream<T>comparator - невмешательство, не сохраняющее состояние Comparator использовать, чтобы сравнить элементы этого потокаOptional описание минимального элемента этого потока, или пустого Optional если поток пустpublic long count()
Stream
return mapToLong(e -> 1L).sum();
Это - терминальная работа.
public boolean anyMatch(Predicate<? super T> predicate)
StreamanyMatch в интерфейсе Stream<T>predicate - невмешательство, предикат не сохраняющий состояние, чтобы примениться к элементам этого потокаtrue если какие-либо элементы потока соответствуют обеспеченный предикат иначе falsepublic boolean allMatch(Predicate<? super T> predicate)
StreamallMatch в интерфейсе Stream<T>predicate - невмешательство, предикат не сохраняющий состояние, чтобы примениться к элементам этого потокаtrue если все элементы потока соответствуют обеспеченный предикат иначе falsepublic boolean noneMatch(Predicate<? super T> predicate)
StreamnoneMatch в интерфейсе Stream<T>predicate - невмешательство, предикат не сохраняющий состояние, чтобы примениться к элементам этого потокаtrue если никакие элементы потока не соответствуют обеспеченный предикат иначе falsepublic Optional<T> findFirst()
StreamOptional описание первого элемента этого потока (во встретиться порядке), или пустое Optional если поток пуст. Если поток имеет, не встречаются с порядком, чем любой элемент может быть возвращен. public Optional<T> findAny()
StreamOptional описание некоторого элемента потока, или пустого 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