Toggle navigation
Home
io.reactivex.Observable to io.reactivex.Flowable
No. of Instances - 3
No. of Commits - 1
No. of Projects - {'pentaho-kettle'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: External -> External
Mapping:
Rename Variable
observable
to
flowable
observable
to
flowable
Add or Remove Method invocation
buffer.observeOn(Schedulers.io()).filter(list -> !list.isEmpty()).map(this::sendBufferToSubtrans).takeWhile(pair -> pair.getValue().getNrErrors() == 0).doOnNext(postProcessor).map(Map.Entry::getValue)
to
buffer.parallel(parallelism).runOn(Schedulers.io()).filter(list -> !list.isEmpty()).map(this::sendBufferToSubtrans).sequential().takeWhile(pair -> pair.getValue().getNrErrors() == 0).doOnNext(postProcessor).map(Map.Entry::getValue)