org.infinispan.stream.impl.intops

Interface IntermediateOperation<InputType,InputStream extends BaseStream<InputType,InputStream>,OutputType,OutputStream extends BaseStream<OutputType,OutputStream>>

Type Parameters:

InputType - the type of the input stream

InputStream - the input stream type

OutputType - the type of the output stream

OutputStream - the output stream type

All Known Subinterfaces:

FlatMappingOperation<InputType,InputStream,OutputType,OutputStream>, MappingOperation<InputType,InputStream,OutputType,OutputStream>

All Known Implementing Classes:

AsDoubleIntOperation, AsDoubleLongOperation, AsLongIntOperation, BoxedDoubleOperation, BoxedIntOperation, BoxedLongOperation, DistinctDoubleOperation, DistinctIntOperation, DistinctLongOperation, DistinctOperation, FilterDoubleOperation, FilterIntOperation, FilterLongOperation, FilterOperation, FlatMapDoubleOperation, FlatMapIntOperation, FlatMapLongOperation, FlatMapOperation, FlatMapToDoubleOperation, FlatMapToIntOperation, FlatMapToLongOperation, LimitDoubleOperation, LimitIntOperation, LimitLongOperation, LimitOperation, MapDoubleOperation, MapIntOperation, MapLongOperation, MapOperation, MapToDoubleIntOperation, MapToDoubleLongOperation, MapToDoubleOperation, MapToIntDoubleOperation, MapToIntLongOperation, MapToIntOperation, MapToLongDoubleOperation, MapToLongIntOperation, MapToLongOperation, MapToObjDoubleOperation, MapToObjIntOperation, MapToObjLongOperation, PeekDoubleOperation, PeekIntOperation, PeekLongOperation, PeekOperation, SkipDoubleOperation, SkipIntOperation, SkipLongOperation, SkipOperation, SortedComparatorOperation, SortedDoubleOperation, SortedIntOperation, SortedLongOperation, SortedOperation, UnorderedOperation

public interface IntermediateOperation<InputType,InputStream extends BaseStream<InputType,InputStream>,OutputType,OutputStream extends BaseStream<OutputType,OutputStream>>

Intermediate operation that can be applied to a stream to change its processing.

Method Summary

Modifier and Type	Method and Description
default void	handleInjection(ComponentRegistry registry) Handles injection of components for various dependencies that the intermediate operation has
io.reactivex.rxjava3.core.Flowable<OutputType>	mapFlowable(io.reactivex.rxjava3.core.Flowable<InputType> input) Performs the intermediate operation on a Flowable.
OutputStream	perform(InputStream stream) Performs the actualy intermediate operation returning the resulting stream

Method Detail

perform

OutputStream perform(InputStream stream)

Performs the actualy intermediate operation returning the resulting stream

Parameters:

stream - the stream to have the operation performed on

Returns:

the resulting stream after the operation was applied

mapFlowable

io.reactivex.rxjava3.core.Flowable<OutputType> mapFlowable(io.reactivex.rxjava3.core.Flowable<InputType> input)

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

Parameters:

input - the input flowable

Returns:

handleInjection

default void handleInjection(ComponentRegistry registry)

Handles injection of components for various dependencies that the intermediate operation has

Parameters:

registry - the registry to use