Source file "reactor/core/publisher/ParallelFlux.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 941 of 941 | 0% | 42 of 42 | 0% | 101 | 101 | 171 | 171 | 80 | 80 |
| sortedMerger(List, List, Comparator) | | 0% | | 0% | 13 | 13 | 23 | 23 | 1 | 1 |
| subscribe(Consumer, Consumer, Runnable, Consumer, Context) | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| validate(Subscriber[]) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| transformGroups(Function) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| onAssembly(ParallelFlux) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| collectSortedList(Comparator, int) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| sorted(Comparator, int) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| checkpoint(String, boolean) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| from(Publisher, int, int, Supplier) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| doOnEach(Consumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| doOnTerminate(Runnable) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| reduce(Supplier, BiFunction) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| doAfterTerminate(Runnable) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| doOnCancel(Runnable) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| doOnComplete(Runnable) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| doOnError(Consumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| doOnSubscribe(Consumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| doOnNext(Consumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| doOnRequest(LongConsumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| checkpoint() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| flatMap(Function, boolean, int, int) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| log(String, Level, boolean, SignalType[]) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| runOn(Scheduler, int) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| doOnSignal(ParallelFlux, Consumer, Consumer, Consumer, Runnable, Runnable, Consumer, LongConsumer, Runnable) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| subscribe(Subscriber) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| subscribe(CoreSubscriber) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| filter(Predicate) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| map(Function) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| reduce(BiFunction) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| concatMap(Function, int, FluxConcatMap.ErrorMode) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| concatMapDelayError(Function, boolean, int) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| checkpoint(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sequential(int) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| subscribe(Consumer, Consumer, Runnable) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| collect(Supplier, BiConsumer) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| subscribe(Consumer, Consumer, Runnable, Consumer) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| subscribe(Consumer, Consumer, Runnable, Context) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| flatMap(Function) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| flatMap(Function, boolean) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| flatMap(Function, boolean, int) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| log() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| log(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| log(String, Level, SignalType[]) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| ordered(Comparator, int) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| from(Publisher) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| from(Publisher, int) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| from(Publisher[]) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| concatMap(Function) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| concatMap(Function, int) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| concatMapDelayError(Function) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| groups() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| subscribe() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| subscribe(Consumer) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| subscribe(Consumer, Consumer) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| then() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| transform(Function) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| concatMapDelayError(Function, int) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$sorted$9(List, Object) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$doOnEach$5(Consumer, Context, Throwable) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$doOnEach$4(Consumer, Context, Object) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$collectSortedList$1(List, Object) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| collectSortedList(Comparator) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| hide() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| ordered(Comparator) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| runOn(Scheduler) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sorted(Comparator) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| tag(String, String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$sorted$10(Comparator, List) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$sorted$8(int) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$doOnEach$6(Consumer, Context) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$collectSortedList$3(Comparator, List, List) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$collectSortedList$2(Comparator, List) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$collectSortedList$0(int) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| as(Function) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| name(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sequential() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| toString() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| ParallelFlux() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$doOnTerminate$7(Runnable, Throwable) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getPrefetch() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |