Uses of Interface
com.tangosol.util.stream.RemoteStream

Packages that use RemoteStream

Package	Description
com.oracle.coherence.repository	Contains classes to enable Repository-like access to Coherence data.
com.tangosol.util	Contains various generic utilities.
com.tangosol.util.stream	Contains classes to support functional-style operations on remote streams of elements, such as map-reduce transformations on collections.

Uses of RemoteStream in com.oracle.coherence.repository

Methods in com.oracle.coherence.repository that return RemoteStream

Modifier and Type	Method	Description
RemoteStream<T>	AbstractRepository.stream()	Return a stream of all entities in this repository.
RemoteStream<T>	AbstractRepository.stream(Filter<?> filter)	Return a stream of all entities in this repository that satisfy the specified criteria.
RemoteStream<T>	AbstractRepository.stream(Collection<? extends ID> colIds)	Return a stream of entities with the specified identifiers.

Uses of RemoteStream in com.tangosol.util

Methods in com.tangosol.util that return RemoteStream

Modifier and Type	Method	Description
default RemoteStream<InvocableMap.Entry<K,V>>	InvocableMap.stream()	Return a stream of all entries in this map.
default RemoteStream<InvocableMap.Entry<K,V>>	InvocableMap.stream(Filter filter)	Return a filtered stream of entries in this map.
default <T,E> RemoteStream<E>	InvocableMap.stream(Filter filter, ValueExtractor<T,? extends E> extractor)	Return a stream of values extracted from all the entries that satisfy the specified filter.
default <T,E> RemoteStream<E>	InvocableMap.stream(ValueExtractor<T,? extends E> extractor)	Return a stream of values extracted from the entries of this map.
default RemoteStream<InvocableMap.Entry<K,V>>	InvocableMap.stream(Collection<? extends K> collKeys)	Return a stream of entries with the specified keys.
default <T,E> RemoteStream<E>	InvocableMap.stream(Collection<? extends K> collKeys, ValueExtractor<T,? extends E> extractor)	Return a stream of values extracted from the entries with the specified keys.

Uses of RemoteStream in com.tangosol.util.stream

Methods in com.tangosol.util.stream that return RemoteStream

Modifier and Type	Method	Description
RemoteStream<Double>	RemoteDoubleStream.boxed()	Returns a Stream consisting of the elements of this stream, boxed to Double.
RemoteStream<Integer>	RemoteIntStream.boxed()	Returns a Stream consisting of the elements of this stream, each boxed to an Integer.
RemoteStream<Long>	RemoteLongStream.boxed()	Returns a Stream consisting of the elements of this stream, each boxed to a Long.
static <K,V> RemoteStream<InvocableMap.Entry<K,V>>	RemoteStream.entrySet(InvocableMap<K,V> map)	Create a RemoteStream of specified map's entries.
default RemoteStream<T>	RemoteStream.filter(Remote.Predicate<? super T> predicate)	Returns a stream consisting of the elements of this stream that match the given predicate.
RemoteStream<T>	RemoteStream.filter(Predicate<? super T> predicate)	Returns a stream consisting of the elements of this stream that match the given predicate.
default <R> RemoteStream<R>	RemoteStream.flatMap(Remote.Function<? super T,? extends Stream<? extends R>> mapper)	Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
<R> RemoteStream<R>	RemoteStream.flatMap(Function<? super T,? extends Stream<? extends R>> mapper)	Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
static <K,V> RemoteStream<K>	RemoteStream.keySet(InvocableMap<K,V> map)	Create a RemoteStream of specified map's keys.
default <R> RemoteStream<R>	RemoteStream.map(Remote.Function<? super T,? extends R> mapper)	Returns a stream consisting of the results of applying the given function to the elements of this stream.
default <R> RemoteStream<R>	RemoteStream.map(ValueExtractor<? super T,? extends R> mapper)	Returns a stream consisting of the results of applying the given extractor to the elements of this stream.
<R> RemoteStream<R>	RemoteStream.map(Function<? super T,? extends R> mapper)	Returns a stream consisting of the results of applying the given function to the elements of this stream.
default <U> RemoteStream<U>	RemoteDoubleStream.mapToObj(Remote.DoubleFunction<? extends U> mapper)	Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.
<U> RemoteStream<U>	RemoteDoubleStream.mapToObj(DoubleFunction<? extends U> mapper)	Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.
default <U> RemoteStream<U>	RemoteIntStream.mapToObj(Remote.IntFunction<? extends U> mapper)	Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.
<U> RemoteStream<U>	RemoteIntStream.mapToObj(IntFunction<? extends U> mapper)	Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.
default <U> RemoteStream<U>	RemoteLongStream.mapToObj(Remote.LongFunction<? extends U> mapper)	Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.
<U> RemoteStream<U>	RemoteLongStream.mapToObj(LongFunction<? extends U> mapper)	Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.
RemoteStream<T>	RemoteStream.parallel()	Returns an equivalent stream that is parallel.
default RemoteStream<T>	RemoteStream.peek(Remote.Consumer<? super T> action)	Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
RemoteStream<T>	RemoteStream.peek(Consumer<? super T> action)	Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
RemoteStream<T>	RemoteStream.sequential()	Returns an equivalent stream that is sequential.
RemoteStream<T>	RemoteStream.sorted()	Returns a stream consisting of the elements of this stream, sorted according to natural order.
default RemoteStream<T>	RemoteStream.sorted(Remote.Comparator<? super T> comparator)	Returns a stream consisting of the elements of this stream, sorted according to the provided Comparator.
default RemoteStream<T>	RemoteStream.sorted(Remote.Comparator<? super T> comparator, boolean fInverse)	Returns a stream consisting of the elements of this stream, sorted according to the provided Comparator.
default <U> RemoteStream<T>	RemoteStream.sorted(ValueExtractor<? super U,? extends Comparable> extractor)	Returns a stream consisting of the elements of this stream, sorted according to attribute extracted by the provided ValueExtractor.
default <U> RemoteStream<T>	RemoteStream.sorted(ValueExtractor<? super U,? extends Comparable> extractor, boolean fInverse)	Returns a stream consisting of the elements of this stream, sorted according to attribute extracted by the provided ValueExtractor.
RemoteStream<T>	RemoteStream.sorted(Comparator<? super T> comparator)	Returns a stream consisting of the elements of this stream, sorted according to the provided Comparator.
RemoteStream<T>	RemoteStream.unordered()	Returns an equivalent stream that is unordered.
static <K,V> RemoteStream<V>	RemoteStream.values(InvocableMap<K,V> map)	Create a RemoteStream of specified map's values.

Methods in com.tangosol.util.stream with parameters of type RemoteStream

Modifier and Type	Method	Description
static <T extends Number> RemoteDoubleStream	RemoteStream.toDoubleStream(RemoteStream<T> stream)	Convert stream of numbers into RemoteDoubleStream.
static <T extends Number> RemoteIntStream	RemoteStream.toIntStream(RemoteStream<T> stream)	Convert stream of numbers into RemoteIntStream.
static <T extends Number> RemoteLongStream	RemoteStream.toLongStream(RemoteStream<T> stream)	Convert stream of numbers into RemoteLongStream.