public class PeekDoubleOperation extends Object implements IntermediateOperation<Double,DoubleStream,Double,DoubleStream>
DoubleStream
Constructor and Description |
---|
PeekDoubleOperation(DoubleConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
DoubleConsumer |
getConsumer() |
void |
handleInjection(ComponentRegistry registry)
Handles injection of components for various dependencies that the intermediate operation has
|
io.reactivex.rxjava3.core.Flowable<Double> |
mapFlowable(io.reactivex.rxjava3.core.Flowable<Double> input)
Performs the intermediate operation on a Flowable.
|
DoubleStream |
perform(DoubleStream stream)
Performs the actualy intermediate operation returning the resulting stream
|
public PeekDoubleOperation(DoubleConsumer consumer)
public DoubleStream perform(DoubleStream stream)
IntermediateOperation
perform
in interface IntermediateOperation<Double,DoubleStream,Double,DoubleStream>
stream
- the stream to have the operation performed onpublic DoubleConsumer getConsumer()
public void handleInjection(ComponentRegistry registry)
IntermediateOperation
handleInjection
in interface IntermediateOperation<Double,DoubleStream,Double,DoubleStream>
registry
- the registry to usepublic io.reactivex.rxjava3.core.Flowable<Double> mapFlowable(io.reactivex.rxjava3.core.Flowable<Double> input)
IntermediateOperation
mapFlowable
in interface IntermediateOperation<Double,DoubleStream,Double,DoubleStream>
input
- the input flowableCopyright © 2021 JBoss by Red Hat. All rights reserved.