I
- the type of the input streamO
- the type of the output streampublic class FlatMapOperation<I,O> extends Object implements FlatMappingOperation<I,Stream<I>,O,Stream<O>>
Stream
Constructor and Description |
---|
FlatMapOperation(Function<? super I,? extends Stream<? extends O>> function) |
Modifier and Type | Method and Description |
---|---|
Function<? super I,? extends Stream<? extends O>> |
getFunction() |
void |
handleInjection(ComponentRegistry registry)
Handles injection of components for various dependencies that the intermediate operation has
|
Stream<Stream<O>> |
map(Stream<I> iStream)
Instead of flat mapping this returns a stream of
OutputStream . |
io.reactivex.rxjava3.core.Flowable<O> |
mapFlowable(io.reactivex.rxjava3.core.Flowable<I> input)
Performs the intermediate operation on a Flowable.
|
Stream<O> |
perform(Stream<I> stream)
Performs the actualy intermediate operation returning the resulting stream
|
public Stream<O> perform(Stream<I> stream)
IntermediateOperation
public void handleInjection(ComponentRegistry registry)
IntermediateOperation
handleInjection
in interface IntermediateOperation<I,Stream<I>,O,Stream<O>>
registry
- the registry to usepublic Stream<Stream<O>> map(Stream<I> iStream)
FlatMappingOperation
OutputStream
.public io.reactivex.rxjava3.core.Flowable<O> mapFlowable(io.reactivex.rxjava3.core.Flowable<I> input)
IntermediateOperation
mapFlowable
in interface IntermediateOperation<I,Stream<I>,O,Stream<O>>
input
- the input flowableCopyright © 2021 JBoss by Red Hat. All rights reserved.