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