Flux

Source file "reactor/core/publisher/Flux.java" was not found during generation of report.

Element	Missed Instructions	Cov.	Missed Branches	Cov.	Missed	Cxty	Missed	Lines	Missed	Methods
Total	4,768 of 4,768	0%	248 of 248	0%	595	595	876	876	471	471
wrap(Publisher)		0%		0%	7	7	17	17	1	1
subscribe(Subscriber)		0%		0%	8	8	21	21	1	1
combineLatest(Function, int, Publisher[])		0%		0%	4	4	9	9	1	1
zip(Function, int, Publisher[])		0%		0%	4	4	9	9	1	1
single()		0%		0%	4	4	13	13	1	1
single(Object)		0%		0%	4	4	13	13	1	1
last(Object)		0%		0%	4	4	13	13	1	1
collectList()		0%		0%	3	3	11	11	1	1
publishOn(Scheduler, boolean, int, int)		0%		0%	3	3	8	8	1	1
zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher)		0%		n/a	1	1	1	1	1	1
subscribeOn(Scheduler, boolean)		0%		0%	3	3	8	8	1	1
zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher)		0%		n/a	1	1	1	1	1	1
timeout(Duration, Publisher, Scheduler)		0%		0%	2	2	5	5	1	1
mergeSequential(int, boolean, Publisher[])		0%		0%	4	4	6	6	1	1
wrapToMono(Callable)		0%		0%	3	3	10	10	1	1
last()		0%		0%	3	3	7	7	1	1
combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function)		0%		n/a	1	1	1	1	1	1
zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher)		0%		n/a	1	1	1	1	1	1
doOnSignal(Flux, Consumer, Consumer, Consumer, Runnable, Runnable, LongConsumer, Runnable)		0%		0%	2	2	3	3	1	1
merge(int, boolean, Publisher[])		0%		0%	3	3	7	7	1	1
log(Logger, Level, boolean, SignalType[])		0%		0%	2	2	4	4	1	1
concatMapDelayError(Function, boolean, int)		0%		0%	3	3	4	4	1	1
log(String, Level, boolean, SignalType[])		0%		0%	2	2	4	4	1	1
or(Publisher)		0%		0%	3	3	6	6	1	1
take(long, boolean)		0%		0%	3	3	5	5	1	1
onAssembly(Flux)		0%		0%	3	3	7	7	1	1
onAssembly(ConnectableFlux)		0%		0%	3	3	7	7	1	1
combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Function)		0%		n/a	1	1	1	1	1	1
zip(Publisher, Publisher, Publisher, Publisher, Publisher)		0%		n/a	1	1	1	1	1	1
replay(int, Duration, Scheduler)		0%		0%	2	2	4	4	1	1
thenMany(Publisher)		0%		0%	2	2	5	5	1	1
mergeOrderedWith(Publisher, Comparator)		0%		0%	2	2	4	4	1	1
mergeComparingWith(Publisher, Comparator)		0%		0%	2	2	4	4	1	1
mergeComparing(int, Comparator, Publisher[])		0%		0%	3	3	5	5	1	1
mergeComparingDelayError(int, Comparator, Publisher[])		0%		0%	3	3	5	5	1	1
mergeOrdered(int, Comparator, Publisher[])		0%		0%	3	3	5	5	1	1
distinct(Function, Supplier, BiPredicate, Consumer)		0%		0%	2	2	3	3	1	1
mergeWith(Publisher)		0%		0%	2	2	4	4	1	1
checkpoint(String, boolean)		0%		0%	2	2	4	4	1	1
concatWith(Publisher)		0%		0%	2	2	4	4	1	1
startWith(Publisher)		0%		0%	2	2	4	4	1	1
combineLatest(Publisher, Publisher, Publisher, Publisher, Function)		0%		n/a	1	1	1	1	1	1
firstWithValue(Publisher, Publisher[])		0%		0%	3	3	6	6	1	1
switchOnNext(Publisher, int)		0%		0%	2	2	6	6	1	1
zip(Publisher, Publisher, Publisher, Publisher)		0%		n/a	1	1	1	1	1	1
concatMap(Function, int)		0%		0%	2	2	3	3	1	1
doFirst(Runnable)		0%		0%	2	2	4	4	1	1
repeat(long, BooleanSupplier)		0%		0%	3	3	5	5	1	1
lambda$transformDeferredContextual$40(BiFunction, ContextView)		0%		0%	2	2	5	5	1	1
fromArray(Object[])		0%		0%	3	3	5	5	1	1
replay(int)		0%		0%	2	2	3	3	1	1
zipWith(Publisher, BiFunction)		0%		0%	3	3	6	6	1	1
buffer(Duration, Duration, Scheduler)		0%		0%	2	2	3	3	1	1
collectMap(Function, Function, Supplier)		0%		n/a	1	1	4	4	1	1
collectMultimap(Function, Function, Supplier)		0%		n/a	1	1	4	4	1	1
metrics()		0%		0%	3	3	5	5	1	1
switchMap(Function, int)		0%		0%	2	2	3	3	1	1
range(int, int)		0%		0%	3	3	5	5	1	1
flatMap(Function, Function, Supplier)		0%		n/a	1	1	4	4	1	1
onBackpressureBuffer(Duration, int, Consumer, Scheduler)		0%		n/a	1	1	3	3	1	1
singleOrEmpty()		0%		0%	2	2	4	4	1	1
window(Duration, Duration, Scheduler)		0%		0%	2	2	3	3	1	1
combineLatest(Publisher, Publisher, Publisher, Function)		0%		n/a	1	1	1	1	1	1
zip(Publisher, Publisher, Publisher)		0%		n/a	1	1	1	1	1	1
doOnEach(Consumer)		0%		0%	2	2	3	3	1	1
filter(Predicate)		0%		0%	2	2	3	3	1	1
handle(BiConsumer)		0%		0%	2	2	3	3	1	1
index(BiFunction)		0%		0%	2	2	3	3	1	1
map(Function)		0%		0%	2	2	3	3	1	1
onBackpressureBuffer(int, Consumer, BufferOverflowStrategy)		0%		n/a	1	1	3	3	1	1
reduce(BiFunction)		0%		0%	2	2	4	4	1	1
tap(SignalListenerFactory)		0%		0%	2	2	3	3	1	1
windowUntil(Predicate, boolean, int)		0%		0%	2	2	3	3	1	1
mergeSequential(Iterable, boolean, int, int)		0%		0%	2	2	2	2	1	1
lambda$collectMultimap$15(Function, Function, Map, Object)		0%		n/a	1	1	4	4	1	1
next()		0%		0%	2	2	4	4	1	1
onErrorReturn(Predicate, Object)		0%		n/a	1	1	3	3	1	1
takeLast(int)		0%		0%	2	2	3	3	1	1
toIterable(int, Supplier)		0%		0%	2	2	4	4	1	1
lambda$transformDeferred$38(Function)		0%		0%	2	2	4	4	1	1
merge(Publisher, int, int)		0%		n/a	1	1	5	5	1	1
doOnError(Class, Consumer)		0%		n/a	1	1	3	3	1	1
doOnTerminate(Runnable)		0%		n/a	1	1	2	2	1	1
onErrorResume(Class, Function)		0%		n/a	1	1	3	3	1	1
zipWith(Publisher, int, BiFunction)		0%		n/a	1	1	1	1	1	1
mergeSequential(Publisher, boolean, int, int)		0%		0%	2	2	2	2	1	1
lambda$collectList$10(Callable)		0%		0%	2	2	5	5	1	1
combineLatest(Publisher, Publisher, BiFunction)		0%		n/a	1	1	1	1	1	1
error(Throwable, boolean)		0%		0%	2	2	3	3	1	1
zip(Publisher, Function)		0%		n/a	1	1	2	2	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
doOnNext(Consumer)		0%		n/a	1	1	2	2	1	1
doOnRequest(LongConsumer)		0%		n/a	1	1	2	2	1	1
doOnSubscribe(Consumer)		0%		n/a	1	1	2	2	1	1
groupJoin(Publisher, Function, Function, BiFunction)		0%		n/a	1	1	3	3	1	1
take(Duration, Scheduler)		0%		0%	2	2	3	3	1	1
transform(Function)		0%		0%	2	2	3	3	1	1
flatMap(Function, boolean, int, int)		0%		n/a	1	1	3	3	1	1
flatMapSequential(Function, boolean, int, int)		0%		0%	2	2	1	1	1	1
blockFirst(Duration)		0%		n/a	1	1	3	3	1	1
blockLast(Duration)		0%		n/a	1	1	3	3	1	1
bufferUntil(Predicate, boolean)		0%		0%	2	2	1	1	1	1
groupBy(Function, Function, int)		0%		n/a	1	1	3	3	1	1
onBackpressureBuffer(int, Consumer)		0%		n/a	1	1	2	2	1	1
onBackpressureBuffer(int, BufferOverflowStrategy)		0%		n/a	1	1	2	2	1	1
onErrorReturn(Class, Object)		0%		n/a	1	1	2	2	1	1
repeat(long)		0%		0%	2	2	3	3	1	1
skip(long)		0%		0%	2	2	3	3	1	1
windowWhile(Predicate, int)		0%		n/a	1	1	3	3	1	1
static {...}		0%		n/a	1	1	6	6	1	1
from(Publisher)		0%		0%	2	2	4	4	1	1
bufferTimeout(int, Duration, Scheduler, Supplier)		0%		n/a	1	1	1	1	1	1
cast(Class)		0%		n/a	1	1	2	2	1	1
onErrorComplete(Class)		0%		n/a	1	1	2	2	1	1
onErrorComplete(Predicate)		0%		n/a	1	1	2	2	1	1
onErrorContinue(Predicate, BiConsumer)		0%		n/a	1	1	4	4	1	1
onErrorReturn(Object)		0%		n/a	1	1	2	2	1	1
share()		0%		n/a	1	1	2	2	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
then(Mono)		0%		n/a	1	1	1	1	1	1
window(int, int)		0%		n/a	1	1	3	3	1	1
windowTimeout(int, Duration, Scheduler, boolean)		0%		n/a	1	1	1	1	1	1
countingBooleanSupplier(BooleanSupplier, long)		0%		0%	2	2	3	3	1	1
countingPredicate(Predicate, long)		0%		0%	2	2	3	3	1	1
lambda$onErrorResume$29(Predicate, Function, Throwable)		0%		0%	2	2	1	1	1	1
lambda$collectList$9(Object)		0%		0%	2	2	4	4	1	1
fromStream(Stream)		0%		n/a	1	1	2	2	1	1
interval(Duration, Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
bufferWhen(Publisher, Function, Supplier)		0%		n/a	1	1	2	2	1	1
doFinally(Consumer)		0%		n/a	1	1	2	2	1	1
elapsed(Scheduler)		0%		n/a	1	1	2	2	1	1
ofType(Class)		0%		n/a	1	1	2	2	1	1
onErrorMap(Class, Function)		0%		n/a	1	1	2	2	1	1
skip(Duration, Scheduler)		0%		0%	2	2	3	3	1	1
skipLast(int)		0%		0%	2	2	3	3	1	1
toStream(int)		0%		n/a	1	1	2	2	1	1
combineLatest(Iterable, int, Function)		0%		n/a	1	1	2	2	1	1
generate(Consumer)		0%		n/a	1	1	2	2	1	1
usingWhen(Publisher, Function, Function, BiFunction, Function)		0%		n/a	1	1	1	1	1	1
zip(Publisher, Publisher, BiFunction)		0%		n/a	1	1	2	2	1	1
zip(Iterable, int, Function)		0%		n/a	1	1	2	2	1	1
blockFirst()		0%		n/a	1	1	3	3	1	1
blockLast()		0%		n/a	1	1	3	3	1	1
concatMapIterable(Function, int)		0%		n/a	1	1	2	2	1	1
doOnError(Predicate, Consumer)		0%		n/a	1	1	2	2	1	1
flatMapIterable(Function, int)		0%		n/a	1	1	2	2	1	1
join(Publisher, Function, Function, BiFunction)		0%		n/a	1	1	1	1	1	1
onErrorResume(Predicate, Function)		0%		n/a	1	1	2	2	1	1
publish(Function, int)		0%		n/a	1	1	2	2	1	1
scan(Object, BiFunction)		0%		n/a	1	1	2	2	1	1
subscribe(Consumer)		0%		n/a	1	1	2	2	1	1
subscribe(Consumer, Consumer)		0%		n/a	1	1	2	2	1	1
windowWhen(Publisher, Function)		0%		n/a	1	1	2	2	1	1
lambda$mapNotNull$24(Function, Object, SynchronousSink)		0%		0%	2	2	4	4	1	1
lambda$collectMap$12(Function, Function, Map, Object)		0%		n/a	1	1	1	1	1	1
using(Callable, Function, Consumer, boolean)		0%		n/a	1	1	1	1	1	1
buffer(int, int, Supplier)		0%		n/a	1	1	1	1	1	1
bufferUntil(Predicate)		0%		n/a	1	1	2	2	1	1
bufferWhile(Predicate)		0%		n/a	1	1	2	2	1	1
elementAt(int, Object)		0%		n/a	1	1	1	1	1	1
expandDeep(Function, int)		0%		n/a	1	1	1	1	1	1
expand(Function, int)		0%		n/a	1	1	1	1	1	1
hasElement(Object)		0%		n/a	1	1	2	2	1	1
onBackpressureBuffer()		0%		n/a	1	1	1	1	1	1
onBackpressureBuffer(int)		0%		n/a	1	1	1	1	1	1
onErrorContinue(BiConsumer)		0%		n/a	1	1	3	3	1	1
onErrorContinue(Class, BiConsumer)		0%		n/a	1	1	1	1	1	1
publish(int)		0%		n/a	1	1	2	2	1	1
sampleTimeout(Function, int)		0%		n/a	1	1	2	2	1	1
timeout(Publisher, Function, String)		0%		n/a	1	1	1	1	1	1
timeout(Publisher, Function, Publisher)		0%		n/a	1	1	1	1	1	1
timestamp(Scheduler)		0%		n/a	1	1	2	2	1	1
window(int)		0%		n/a	1	1	1	1	1	1
window(Publisher)		0%		n/a	1	1	2	2	1	1
lambda$zipWith$43(BiFunction, Object[])		0%		n/a	1	1	1	1	1	1
lambda$windowUntilChanged$42(Function, BiPredicate)		0%		n/a	1	1	1	1	1	1
lambda$bufferUntilChanged$8(Function, BiPredicate)		0%		n/a	1	1	1	1	1	1
lambda$zip$6(Function, Object)		0%		n/a	1	1	1	1	1	1
lambda$zip$5(Function, Object)		0%		n/a	1	1	1	1	1	1
lambda$combineLatest$2(BiFunction, Object[])		0%		n/a	1	1	1	1	1	1
lambda$combineLatest$1(Function, Object)		0%		n/a	1	1	1	1	1	1
lambda$combineLatest$0(Function, Object)		0%		n/a	1	1	1	1	1	1
create(Consumer, FluxSink.OverflowStrategy)		0%		n/a	1	1	1	1	1	1
push(Consumer, FluxSink.OverflowStrategy)		0%		n/a	1	1	1	1	1	1
generate(Callable, BiFunction, Consumer)		0%		n/a	1	1	1	1	1	1
switchOnNext(Publisher)		0%		n/a	1	1	2	2	1	1
usingWhen(Publisher, Function, Function)		0%		n/a	1	1	1	1	1	1
buffer(int, Supplier)		0%		n/a	1	1	1	1	1	1
buffer(Publisher, Supplier)		0%		n/a	1	1	1	1	1	1
collect(Supplier, BiConsumer)		0%		n/a	1	1	1	1	1	1
concatMap(Function)		0%		n/a	1	1	1	1	1	1
delaySequence(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
dematerialize()		0%		n/a	1	1	2	2	1	1
distinctUntilChanged(Function, BiPredicate)		0%		n/a	1	1	1	1	1	1
elementAt(int)		0%		n/a	1	1	1	1	1	1
filterWhen(Function, int)		0%		n/a	1	1	1	1	1	1
limitRate(int, int)		0%		n/a	1	1	1	1	1	1
log(Logger)		0%		n/a	1	1	1	1	1	1
onErrorComplete()		0%		n/a	1	1	1	1	1	1
reduceWith(Supplier, BiFunction)		0%		n/a	1	1	1	1	1	1
scanWith(Supplier, BiFunction)		0%		n/a	1	1	1	1	1	1
shareNext()		0%		n/a	1	1	2	2	1	1
subscribe(Consumer, Consumer, Runnable)		0%		n/a	1	1	1	1	1	1
switchOnFirst(BiFunction, boolean)		0%		n/a	1	1	1	1	1	1
tap(Supplier)		0%		n/a	1	1	1	1	1	1
tap(Function)		0%		n/a	1	1	1	1	1	1
then()		0%		n/a	1	1	2	2	1	1
withLatestFrom(Publisher, BiFunction)		0%		n/a	1	1	1	1	1	1
zipWithIterable(Iterable, BiFunction)		0%		n/a	1	1	1	1	1	1
lambda$doOnError$20(Predicate, Consumer, Throwable)		0%		0%	2	2	3	3	1	1
concat(Publisher[])		0%		n/a	1	1	1	1	1	1
concatDelayError(Publisher, boolean, int)		0%		n/a	1	1	1	1	1	1
concatDelayError(Publisher[])		0%		n/a	1	1	1	1	1	1
generate(Callable, BiFunction)		0%		n/a	1	1	1	1	1	1
all(Predicate)		0%		n/a	1	1	1	1	1	1
any(Predicate)		0%		n/a	1	1	1	1	1	1
bufferTimeout(int, Duration, Supplier)		0%		n/a	1	1	1	1	1	1
bufferTimeout(int, Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
cache(int, Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
cancelOn(Scheduler)		0%		n/a	1	1	1	1	1	1
checkpoint(String)		0%		n/a	1	1	1	1	1	1
collect(Collector)		0%		n/a	1	1	1	1	1	1
contextWrite(Function)		0%		n/a	1	1	1	1	1	1
defaultIfEmpty(Object)		0%		n/a	1	1	1	1	1	1
delaySubscription(Publisher)		0%		n/a	1	1	1	1	1	1
distinct(Function, Supplier)		0%		n/a	1	1	1	1	1	1
flatMap(Function, int, int)		0%		n/a	1	1	1	1	1	1
flatMapDelayError(Function, int, int)		0%		n/a	1	1	1	1	1	1
flatMapSequential(Function, int, int)		0%		n/a	1	1	1	1	1	1
flatMapSequentialDelayError(Function, int, 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
onBackpressureBuffer(Duration, int, Consumer)		0%		n/a	1	1	1	1	1	1
onBackpressureDrop(Consumer)		0%		n/a	1	1	1	1	1	1
onErrorResume(Function)		0%		n/a	1	1	1	1	1	1
parallel(int, int)		0%		n/a	1	1	2	2	1	1
publishOn(Scheduler, boolean, int)		0%		n/a	1	1	1	1	1	1
repeat(BooleanSupplier)		0%		n/a	1	1	1	1	1	1
repeatWhen(Function)		0%		n/a	1	1	1	1	1	1
retry(long)		0%		n/a	1	1	1	1	1	1
retryWhen(Retry)		0%		n/a	1	1	1	1	1	1
sample(Publisher)		0%		n/a	1	1	1	1	1	1
sampleFirst(Function)		0%		n/a	1	1	1	1	1	1
scan(BiFunction)		0%		n/a	1	1	1	1	1	1
skipUntil(Predicate)		0%		n/a	1	1	1	1	1	1
skipUntilOther(Publisher)		0%		n/a	1	1	1	1	1	1
skipWhile(Predicate)		0%		n/a	1	1	1	1	1	1
switchIfEmpty(Publisher)		0%		n/a	1	1	1	1	1	1
switchMap(Function)		0%		n/a	1	1	1	1	1	1
takeUntil(Predicate)		0%		n/a	1	1	1	1	1	1
takeUntilOther(Publisher)		0%		n/a	1	1	1	1	1	1
takeWhile(Predicate)		0%		n/a	1	1	1	1	1	1
timed(Scheduler)		0%		n/a	1	1	1	1	1	1
windowTimeout(int, Duration, boolean)		0%		n/a	1	1	1	1	1	1
windowTimeout(int, Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
lambda$null$39(BiFunction, ContextView, Publisher)		0%		n/a	1	1	1	1	1	1
lambda$timestamp$36(Scheduler, Object)		0%		n/a	1	1	1	1	1	1
concat(Iterable)		0%		n/a	1	1	1	1	1	1
concat(Publisher, int)		0%		n/a	1	1	1	1	1	1
concatDelayError(Publisher, int)		0%		n/a	1	1	1	1	1	1
defer(Supplier)		0%		n/a	1	1	1	1	1	1
deferContextual(Function)		0%		n/a	1	1	1	1	1	1
error(Supplier)		0%		n/a	1	1	1	1	1	1
firstWithSignal(Publisher[])		0%		n/a	1	1	1	1	1	1
firstWithSignal(Iterable)		0%		n/a	1	1	1	1	1	1
firstWithValue(Iterable)		0%		n/a	1	1	1	1	1	1
fromIterable(Iterable)		0%		n/a	1	1	1	1	1	1
fromStream(Supplier)		0%		n/a	1	1	1	1	1	1
just(Object)		0%		n/a	1	1	1	1	1	1
mergeSequential(Publisher)		0%		n/a	1	1	1	1	1	1
mergeSequential(Publisher, int, int)		0%		n/a	1	1	1	1	1	1
mergeSequentialDelayError(Publisher, int, int)		0%		n/a	1	1	1	1	1	1
mergeSequential(Iterable)		0%		n/a	1	1	1	1	1	1
mergeSequential(Iterable, int, int)		0%		n/a	1	1	1	1	1	1
mergeSequentialDelayError(Iterable, int, int)		0%		n/a	1	1	1	1	1	1
using(Callable, Function, Consumer)		0%		n/a	1	1	1	1	1	1
buffer(int, int)		0%		n/a	1	1	1	1	1	1
buffer(Duration, Duration)		0%		n/a	1	1	1	1	1	1
buffer(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
bufferTimeout(int, Duration)		0%		n/a	1	1	1	1	1	1
bufferUntilChanged(Function, BiPredicate)		0%		n/a	1	1	1	1	1	1
bufferWhen(Publisher, Function)		0%		n/a	1	1	1	1	1	1
cache(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
cache(int, Duration)		0%		n/a	1	1	1	1	1	1
collectMap(Function, Function)		0%		n/a	1	1	1	1	1	1
collectMultimap(Function, Function)		0%		n/a	1	1	1	1	1	1
collectSortedList(Comparator)		0%		n/a	1	1	1	1	1	1
concatMapDelayError(Function, int)		0%		n/a	1	1	1	1	1	1
count()		0%		n/a	1	1	1	1	1	1
delayElements(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
delaySubscription(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
doOnDiscard(Class, Consumer)		0%		n/a	1	1	1	1	1	1
flatMap(Function)		0%		n/a	1	1	1	1	1	1
flatMap(Function, int)		0%		n/a	1	1	1	1	1	1
flatMapSequential(Function, int)		0%		n/a	1	1	1	1	1	1
groupBy(Function, int)		0%		n/a	1	1	1	1	1	1
groupBy(Function, Function)		0%		n/a	1	1	1	1	1	1
hasElements()		0%		n/a	1	1	1	1	1	1
ignoreElements()		0%		n/a	1	1	1	1	1	1
limitRate(int)		0%		n/a	1	1	1	1	1	1
materialize()		0%		n/a	1	1	1	1	1	1
onBackpressureDrop()		0%		n/a	1	1	1	1	1	1
onBackpressureLatest()		0%		n/a	1	1	1	1	1	1
onErrorStop()		0%		n/a	1	1	2	2	1	1
onErrorMap(Predicate, Function)		0%		n/a	1	1	1	1	1	1
publishOn(Scheduler, int)		0%		n/a	1	1	1	1	1	1
reduce(Object, BiFunction)		0%		n/a	1	1	1	1	1	1
replay(int, Duration)		0%		n/a	1	1	1	1	1	1
replay(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
sort(Comparator)		0%		n/a	1	1	1	1	1	1
subscribe()		0%		n/a	1	1	1	1	1	1
timeout(Duration)		0%		n/a	1	1	1	1	1	1
timeout(Duration, Publisher)		0%		n/a	1	1	1	1	1	1
timeout(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
timeout(Publisher, Function)		0%		n/a	1	1	1	1	1	1
window(Duration, Duration)		0%		n/a	1	1	1	1	1	1
window(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
windowTimeout(int, Duration)		0%		n/a	1	1	1	1	1	1
windowUntil(Predicate, boolean)		0%		n/a	1	1	1	1	1	1
windowUntilChanged(Function, BiPredicate)		0%		n/a	1	1	1	1	1	1
zipWith(Publisher, int)		0%		n/a	1	1	1	1	1	1
lambda$repeat$31(BooleanSupplier, long)		0%		n/a	1	1	1	1	1	1
lambda$onErrorMap$28(Function, Throwable)		0%		n/a	1	1	1	1	1	1
lambda$onErrorMap$27(Function, Throwable)		0%		n/a	1	1	1	1	1	1
combineLatest(Function, Publisher[])		0%		n/a	1	1	1	1	1	1
combineLatest(Iterable, Function)		0%		n/a	1	1	1	1	1	1
concatWithValues(Object[])		0%		n/a	1	1	1	1	1	1
interval(Duration, Duration)		0%		n/a	1	1	1	1	1	1
interval(Duration, Scheduler)		0%		n/a	1	1	1	1	1	1
merge(Publisher)		0%		n/a	1	1	1	1	1	1
merge(Publisher, int)		0%		n/a	1	1	1	1	1	1
merge(int, Publisher[])		0%		n/a	1	1	1	1	1	1
mergeDelayError(int, Publisher[])		0%		n/a	1	1	1	1	1	1
mergeComparing(Publisher[])		0%		n/a	1	1	1	1	1	1
mergeComparing(Comparator, Publisher[])		0%		n/a	1	1	1	1	1	1
mergeOrdered(Publisher[])		0%		n/a	1	1	1	1	1	1
mergeOrdered(Comparator, Publisher[])		0%		n/a	1	1	1	1	1	1
mergeSequential(Publisher[])		0%		n/a	1	1	1	1	1	1
mergeSequential(int, Publisher[])		0%		n/a	1	1	1	1	1	1
mergeSequentialDelayError(int, Publisher[])		0%		n/a	1	1	1	1	1	1
zip(Publisher, Publisher)		0%		n/a	1	1	1	1	1	1
zip(Iterable, Function)		0%		n/a	1	1	1	1	1	1
zip(Function, Publisher[])		0%		n/a	1	1	1	1	1	1
buffer(int)		0%		n/a	1	1	1	1	1	1
buffer(Publisher)		0%		n/a	1	1	1	1	1	1
buffer(Duration)		0%		n/a	1	1	1	1	1	1
bufferUntilChanged(Function)		0%		n/a	1	1	1	1	1	1
cache(int)		0%		n/a	1	1	1	1	1	1
cache(Duration)		0%		n/a	1	1	1	1	1	1
checkpoint()		0%		n/a	1	1	1	1	1	1
collectMap(Function)		0%		n/a	1	1	1	1	1	1
collectMultimap(Function)		0%		n/a	1	1	1	1	1	1
concatMapDelayError(Function)		0%		n/a	1	1	1	1	1	1
concatMapIterable(Function)		0%		n/a	1	1	1	1	1	1
contextWrite(ContextView)		0%		n/a	1	1	1	1	1	1
delayElements(Duration)		0%		n/a	1	1	1	1	1	1
delaySequence(Duration)		0%		n/a	1	1	1	1	1	1
delayUntil(Function)		0%		n/a	1	1	1	1	1	1
delaySubscription(Duration)		0%		n/a	1	1	1	1	1	1
distinct(Function)		0%		n/a	1	1	1	1	1	1
distinctUntilChanged(Function)		0%		n/a	1	1	1	1	1	1
expandDeep(Function)		0%		n/a	1	1	1	1	1	1
expand(Function)		0%		n/a	1	1	1	1	1	1
filterWhen(Function)		0%		n/a	1	1	1	1	1	1
flatMapIterable(Function)		0%		n/a	1	1	1	1	1	1
flatMapSequential(Function)		0%		n/a	1	1	1	1	1	1
groupBy(Function)		0%		n/a	1	1	1	1	1	1
hide()		0%		n/a	1	1	1	1	1	1
limitRequest(long)		0%		n/a	1	1	1	1	1	1
mapNotNull(Function)		0%		n/a	1	1	1	1	1	1
onErrorMap(Function)		0%		n/a	1	1	1	1	1	1
onTerminateDetach()		0%		n/a	1	1	1	1	1	1
parallel(int)		0%		n/a	1	1	1	1	1	1
publish(Function)		0%		n/a	1	1	1	1	1	1
publishOn(Scheduler)		0%		n/a	1	1	1	1	1	1
replay(Duration)		0%		n/a	1	1	1	1	1	1
sample(Duration)		0%		n/a	1	1	1	1	1	1
sampleFirst(Duration)		0%		n/a	1	1	1	1	1	1
sampleTimeout(Function)		0%		n/a	1	1	1	1	1	1
skip(Duration)		0%		n/a	1	1	1	1	1	1
sort()		0%		n/a	1	1	1	1	1	1
startWith(Iterable)		0%		n/a	1	1	1	1	1	1
startWith(Object[])		0%		n/a	1	1	1	1	1	1
subscribeOn(Scheduler)		0%		n/a	1	1	1	1	1	1
subscribeWith(Subscriber)		0%		n/a	1	1	2	2	1	1
switchOnFirst(BiFunction)		0%		n/a	1	1	1	1	1	1
tag(String, String)		0%		n/a	1	1	1	1	1	1
take(long)		0%		n/a	1	1	1	1	1	1
take(Duration)		0%		n/a	1	1	1	1	1	1
thenEmpty(Publisher)		0%		n/a	1	1	1	1	1	1
timeout(Publisher)		0%		n/a	1	1	1	1	1	1
toIterable(int)		0%		n/a	1	1	1	1	1	1
transformDeferred(Function)		0%		n/a	1	1	1	1	1	1
transformDeferredContextual(BiFunction)		0%		n/a	1	1	1	1	1	1
window(Duration)		0%		n/a	1	1	1	1	1	1
windowUntil(Predicate)		0%		n/a	1	1	1	1	1	1
windowUntilChanged(Function)		0%		n/a	1	1	1	1	1	1
windowWhile(Predicate)		0%		n/a	1	1	1	1	1	1
zipWith(Publisher)		0%		n/a	1	1	1	1	1	1
zipWithIterable(Iterable)		0%		n/a	1	1	1	1	1	1
lambda$toIterable$37(Supplier)		0%		n/a	1	1	1	1	1	1
lambda$ofType$25(Class, Object)		0%		n/a	1	1	1	1	1	1
lambda$delayUntil$19(Function, Object)		0%		n/a	1	1	2	2	1	1
lambda$usingWhen$4(Function, Object, Throwable)		0%		n/a	1	1	1	1	1	1
concat(Publisher)		0%		n/a	1	1	1	1	1	1
concatDelayError(Publisher)		0%		n/a	1	1	1	1	1	1
create(Consumer)		0%		n/a	1	1	1	1	1	1
push(Consumer)		0%		n/a	1	1	1	1	1	1
error(Throwable)		0%		n/a	1	1	1	1	1	1
interval(Duration)		0%		n/a	1	1	1	1	1	1
merge(Iterable)		0%		n/a	1	1	1	1	1	1
merge(Publisher[])		0%		n/a	1	1	1	1	1	1
as(Function)		0%		n/a	1	1	1	1	1	1
buffer()		0%		n/a	1	1	1	1	1	1
bufferUntilChanged()		0%		n/a	1	1	1	1	1	1
cache()		0%		n/a	1	1	1	1	1	1
collectSortedList()		0%		n/a	1	1	1	1	1	1
distinct()		0%		n/a	1	1	1	1	1	1
distinctUntilChanged()		0%		n/a	1	1	1	1	1	1
elapsed()		0%		n/a	1	1	1	1	1	1
index()		0%		n/a	1	1	1	1	1	1
name(String)		0%		n/a	1	1	1	1	1	1
onBackpressureError()		0%		n/a	1	1	1	1	1	1
parallel()		0%		n/a	1	1	1	1	1	1
publish()		0%		n/a	1	1	1	1	1	1
repeat()		0%		n/a	1	1	1	1	1	1
replay()		0%		n/a	1	1	1	1	1	1
retry()		0%		n/a	1	1	1	1	1	1
timed()		0%		n/a	1	1	1	1	1	1
timestamp()		0%		n/a	1	1	1	1	1	1
toIterable()		0%		n/a	1	1	1	1	1	1
toStream()		0%		n/a	1	1	1	1	1	1
windowUntilChanged()		0%		n/a	1	1	1	1	1	1
toString()		0%		n/a	1	1	1	1	1	1
lambda$window$41(Duration, Scheduler, Long)		0%		n/a	1	1	1	1	1	1
lambda$hasElement$22(Object, Object)		0%		n/a	1	1	1	1	1	1
lambda$delayElements$18(Duration, Scheduler, Object)		0%		n/a	1	1	1	1	1	1
lambda$contextWrite$17(ContextView, Context)		0%		n/a	1	1	1	1	1	1
lambda$collectSortedList$16(Comparator, List)		0%		n/a	1	1	2	2	1	1
lambda$null$14(Object)		0%		n/a	1	1	1	1	1	1
lambda$collectMultimap$13()		0%		n/a	1	1	1	1	1	1
lambda$collectMap$11()		0%		n/a	1	1	1	1	1	1
lambda$buffer$7(Duration, Scheduler, Long)		0%		n/a	1	1	2	2	1	1
Flux()		0%		n/a	1	1	1	1	1	1
first(Publisher[])		0%		n/a	1	1	1	1	1	1
first(Iterable)		0%		n/a	1	1	1	1	1	1
just(Object[])		0%		n/a	1	1	1	1	1	1
publishNext()		0%		n/a	1	1	1	1	1	1
lambda$sampleFirst$32(Duration, Object)		0%		n/a	1	1	1	1	1	1
lambda$doOnTerminate$21(Runnable, Throwable)		0%		n/a	1	1	1	1	1	1
empty()		0%		n/a	1	1	1	1	1	1
never()		0%		n/a	1	1	1	1	1	1
getPrefetch()		0%		n/a	1	1	1	1	1	1
hashSetSupplier()		0%		n/a	1	1	1	1	1	1
listSupplier()		0%		n/a	1	1	1	1	1	1
equalPredicate()		0%		n/a	1	1	1	1	1	1
identityFunction()		0%		n/a	1	1	1	1	1	1
tuple2Function()		0%		n/a	1	1	1	1	1	1
lambda$static$44()		0%		n/a	1	1	1	1	1	1
lambda$timeout$35(Object)		0%		n/a	1	1	1	1	1	1
lambda$timeout$34(Mono, Object)		0%		n/a	1	1	1	1	1	1
lambda$scan$33(Object)		0%		n/a	1	1	1	1	1	1
lambda$reduce$30(Object)		0%		n/a	1	1	1	1	1	1
lambda$onBackpressureError$26(Object)		0%		n/a	1	1	1	1	1	1
lambda$log$23(Logger, String)		0%		n/a	1	1	1	1	1	1
lambda$fromStream$3(Stream)		0%		n/a	1	1	1	1	1	1