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

Packages that use RemoteStream

Package	Description
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.tangosol.util

Methods in com.tangosol.util that return RemoteStream

Modifier and Type	Method and 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(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.
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.

Uses of RemoteStream in com.tangosol.util.stream

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

Modifier and Type	Method and Description
RemoteStream<Double>	RemoteDoubleStream.boxed() Returns a Stream consisting of the elements of this stream, boxed to Double.
RemoteStream<Long>	RemoteLongStream.boxed() Returns a Stream consisting of the elements of this stream, each boxed to a Long.
RemoteStream<Integer>	RemoteIntStream.boxed() Returns a Stream consisting of the elements of this stream, each boxed to an Integer.
RemoteStream<T>	RemoteStream.filter(Predicate<? super T> predicate) Returns a stream consisting of the elements of this stream that match the given predicate.
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.
<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.
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.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 <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.
<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.
<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.
<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.
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.
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.
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.
RemoteStream<T>	RemoteStream.parallel() Returns an equivalent stream that is parallel.
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.
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.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.
RemoteStream<T>	RemoteStream.sorted(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) 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.unordered() Returns an equivalent stream that is unordered.

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

Modifier and Type	Method and 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.