org.infinispan.stream.impl.intops.object

Class SortedComparatorOperation<S>

java.lang.Object

org.infinispan.stream.impl.intops.object.SortedComparatorOperation<S>

All Implemented Interfaces:

IntermediateOperation<S,Stream<S>,S,Stream<S>>

public class SortedComparatorOperation<S>
extends Object
implements IntermediateOperation<S,Stream<S>,S,Stream<S>>

Performs sorted operation with a comparator on a regular Stream

Constructor Summary

Constructors

Constructor and Description
SortedComparatorOperation(Comparator<? super S> comparator)

Method Summary

Modifier and Type	Method and Description
Comparator<? super S>	getComparator()
io.reactivex.rxjava3.core.Flowable<S>	mapFlowable(io.reactivex.rxjava3.core.Flowable<S> input) Performs the intermediate operation on a Flowable.
Stream<S>	perform(Stream<S> stream) Performs the actualy intermediate operation returning the resulting stream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.stream.impl.intops.IntermediateOperation

handleInjection

Constructor Detail

SortedComparatorOperation

public SortedComparatorOperation(Comparator<? super S> comparator)

Method Detail

perform

public Stream<S> perform(Stream<S> stream)

Description copied from interface: IntermediateOperation

Performs the actualy intermediate operation returning the resulting stream

Specified by:

perform in interface IntermediateOperation<S,Stream<S>,S,Stream<S>>

Parameters:

stream - the stream to have the operation performed on

Returns:

the resulting stream after the operation was applied

getComparator

public Comparator<? super S> getComparator()

mapFlowable

public io.reactivex.rxjava3.core.Flowable<S> mapFlowable(io.reactivex.rxjava3.core.Flowable<S> input)

Description copied from interface: IntermediateOperation

Performs the intermediate operation on a Flowable. This is an interop method to allow Distributed Streams to actually use Distributed Publisher

Specified by:

mapFlowable in interface IntermediateOperation<S,Stream<S>,S,Stream<S>>

Parameters:

input - the input flowable

Returns: