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 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
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

handleInjection

default void handleInjection(ComponentRegistry registry)

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

Parameters:

registry - the registry to use