ParallelFlowable

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total747 of 7470%8 of 80%57571541545353
validate(Subscriber[])510%40%338811
toSortedList(Comparator, int)380%n/a117711
sorted(Comparator, int)350%n/a116611
flatMap(Function, boolean, int, int)220%n/a114411
concatMapDelayError(Function, int, boolean)210%20%224411
from(Publisher, int, int)200%n/a114411
doOnNext(Consumer)180%n/a115511
doAfterNext(Consumer)180%n/a115511
doOnError(Consumer)180%n/a115511
doOnComplete(Action)180%n/a116611
doAfterTerminated(Action)180%n/a116611
doOnSubscribe(Consumer)180%n/a115511
doOnRequest(LongConsumer)180%n/a116611
doOnCancel(Action)180%n/a116611
fromArray(Publisher[])180%20%224411
concatMap(Function, int)170%n/a113311
map(Function, ParallelFailureHandling)160%n/a113311
map(Function, BiFunction)160%n/a113311
filter(Predicate, ParallelFailureHandling)160%n/a113311
filter(Predicate, BiFunction)160%n/a113311
runOn(Scheduler, int)160%n/a113311
reduce(Supplier, BiFunction)160%n/a113311
doOnNext(Consumer, ParallelFailureHandling)160%n/a113311
doOnNext(Consumer, BiFunction)160%n/a113311
collect(Supplier, BiConsumer)160%n/a113311
flatMapIterable(Function, int)160%n/a113311
mapOptional(Function, ParallelFailureHandling)160%n/a113311
mapOptional(Function, BiFunction)160%n/a113311
flatMapStream(Function, int)160%n/a113311
sequential(int)120%n/a112211
sequentialDelayError(int)120%n/a112211
map(Function)110%n/a112211
filter(Predicate)110%n/a112211
reduce(BiFunction)110%n/a112211
mapOptional(Function)110%n/a112211
collect(Collector)110%n/a112211
compose(ParallelTransformer)80%n/a111111
to(ParallelFlowableConverter)70%n/a111111
flatMap(Function)70%n/a111111
flatMap(Function, boolean)70%n/a111111
flatMap(Function, boolean, int)70%n/a111111
from(Publisher)60%n/a111111
concatMapDelayError(Function, boolean)60%n/a111111
from(Publisher, int)50%n/a111111
runOn(Scheduler)50%n/a111111
sorted(Comparator)50%n/a111111
toSortedList(Comparator)50%n/a111111
concatMap(Function)50%n/a111111
flatMapIterable(Function)50%n/a111111
flatMapStream(Function)50%n/a111111
sequential()40%n/a111111
sequentialDelayError()40%n/a111111
ParallelFlowable()30%n/a111111