Flowable

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total7,703 of 7,7030%135 of 1350%6076071,3601,360538538
just(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object)840%n/a11111111
zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function9)840%n/a11111111
combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function9)830%n/a11111111
just(Object, Object, Object, Object, Object, Object, Object, Object, Object)760%n/a11101011
zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function8)760%n/a11101011
combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function8)750%n/a11101011
intervalRange(long, long, long, long, TimeUnit, Scheduler)680%80%55101011
just(Object, Object, Object, Object, Object, Object, Object, Object)680%n/a119911
zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function7)680%n/a119911
combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function7)670%n/a119911
just(Object, Object, Object, Object, Object, Object, Object)600%n/a118811
zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function6)600%n/a118811
combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function6)590%n/a118811
rangeLong(long, long)560%100%66101011
just(Object, Object, Object, Object, Object, Object)520%n/a117711
zip(Publisher, Publisher, Publisher, Publisher, Publisher, Function5)520%n/a117711
combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Function5)510%n/a117711
range(int, int)470%80%559911
withLatestFrom(Publisher, Publisher, Publisher, Publisher, Function5)450%n/a117711
just(Object, Object, Object, Object, Object)440%n/a116611
zip(Publisher, Publisher, Publisher, Publisher, Function4)440%n/a116611
combineLatest(Publisher, Publisher, Publisher, Publisher, Function4)430%n/a116611
merge(Publisher, Publisher, Publisher, Publisher)400%n/a115511
mergeDelayError(Publisher, Publisher, Publisher, Publisher)400%n/a115511
takeLast(long, long, TimeUnit, Scheduler, boolean, int)400%20%226611
takeLast(int)380%60%447711
flatMap(Function, boolean, int, int)370%40%339911
withLatestFrom(Publisher, Publisher, Publisher, Function4)370%n/a116611
concat(Publisher, Publisher, Publisher, Publisher)360%n/a115511
just(Object, Object, Object, Object)360%n/a115511
zip(Publisher, Publisher, Publisher, Function3)360%n/a115511
concatMapDelayError(Function, boolean, int)360%60%448811
subscribe(FlowableSubscriber)360%n/a11141411
combineLatest(Publisher, Publisher, Publisher, Function3)350%n/a115511
fromObservable(ObservableSource, BackpressureStrategy)350%50%559911
subscribe(Consumer, Consumer, Action, DisposableContainer)330%n/a118811
window(long, long, TimeUnit, Scheduler, int)330%n/a116611
merge(Publisher, Publisher, Publisher)320%n/a114411
mergeDelayError(Publisher, Publisher, Publisher)320%n/a114411
concatMap(Function, int)320%40%338811
switchMap0(Function, int, boolean)320%40%338811
skip(long)300%40%335511
buffer(long, TimeUnit, Scheduler, int, Supplier, boolean)290%n/a115511
repeat(long)290%40%335511
window(long, TimeUnit, Scheduler, long, boolean, int)290%n/a115511
withLatestFrom(Publisher, Publisher, Function3)290%n/a115511
concat(Publisher, Publisher, Publisher)280%n/a114411
just(Object, Object, Object)280%n/a114411
zip(Publisher, Publisher, BiFunction)280%n/a114411
zip(Publisher, Publisher, BiFunction, boolean)280%n/a114411
zip(Publisher, Publisher, BiFunction, boolean, int)280%n/a114411
elementAt(long, Object)280%20%224411
retry(long, Predicate)280%20%224411
combineLatest(Publisher, Publisher, BiFunction)270%n/a114411
zipArray(Function, boolean, int, Publisher[])270%20%226611
blockingForEach(Consumer, int)270%20%22101011
groupBy(Function, Function, boolean, int, Function)270%n/a115511
skipLast(long, TimeUnit, Scheduler, boolean, int)270%n/a115511
ambArray(Publisher[])260%40%337711
combineLatestArray(Publisher[], Function, int)260%20%226611
combineLatestArrayDelayError(Publisher[], Function, int)260%20%226611
concatMapDelayError(Function, boolean, int, Scheduler)260%20%224411
concatMapEagerDelayError(Function, boolean, int, int)260%20%224411
doOnEach(Consumer, Consumer, Action, Action)260%n/a115511
groupJoin(Publisher, Function, Function, BiFunction)260%n/a115511
join(Publisher, Function, Function, BiFunction)260%n/a115511
replay(Function, int, long, TimeUnit, Scheduler)260%n/a116611
replay(Function, int, long, TimeUnit, Scheduler, boolean)260%n/a116611
skipLast(int)260%40%335511
concatArray(Publisher[])250%40%336611
concatArrayDelayError(Publisher[])250%40%336611
concatArrayEager(int, int, Publisher[])250%n/a114411
concatEager(Iterable, int, int)250%n/a114411
concatEagerDelayError(Iterable, int, int)250%n/a114411
sequenceEqual(Publisher, Publisher, BiPredicate, int)250%n/a115511
buffer(long, long, TimeUnit, Scheduler, Supplier)250%n/a114411
flatMap(Function, BiFunction, boolean, int, int)250%n/a115511
subscribe(Consumer, Consumer, Action)250%n/a116611
fromArray(Object[])240%40%336611
merge(Publisher, Publisher)240%n/a113311
mergeDelayError(Publisher, Publisher)240%n/a113311
elementAtOrError(long)240%20%223311
forEachWhile(Predicate, Consumer, Action)240%n/a116611
toMultimap(Function, Function, Supplier, Function)240%n/a115511
elementAt(long)230%20%223311
groupBy(Function, Function, boolean, int)230%n/a114411
onBackpressureBuffer(int, boolean, boolean, Action, Consumer)230%n/a114411
sample(long, TimeUnit, Scheduler, boolean, Consumer)230%n/a114411
take(long)230%20%223311
throttleLatest(long, TimeUnit, Scheduler, boolean, Consumer)230%n/a114411
concatEager(Publisher, int, int)220%n/a114411
concatEagerDelayError(Publisher, int, int)220%n/a114411
zip(Iterable, Function, boolean, int)220%n/a114411
concatMap(Function, int, Scheduler)220%n/a114411
concatMapEager(Function, int, int)220%n/a114411
debounce(long, TimeUnit, Scheduler, Consumer)220%n/a114411
flatMap(Function, Function, Supplier, int)220%n/a114411
onBackpressureBuffer(long, Action, BackpressureOverflowStrategy, Consumer)220%n/a114411
throttleFirst(long, TimeUnit, Scheduler, Consumer)220%n/a114411
combineLatest(Iterable, Function, int)210%n/a114411
combineLatestDelayError(Iterable, Function, int)210%n/a114411
interval(long, long, TimeUnit, Scheduler)210%n/a113311
using(Supplier, Function, Consumer, boolean)210%n/a114411
buffer(int, int, Supplier)210%n/a114411
buffer(Publisher, Function, Supplier)210%n/a114411
concatMapCompletableDelayError(Function, boolean, int)210%20%223311
concatMapMaybeDelayError(Function, boolean, int)210%20%223311
concatMapSingleDelayError(Function, boolean, int)210%20%223311
doOnLifecycle(Consumer, LongConsumer, Action)210%n/a114411
flatMap(Function, Function, Supplier)210%n/a114411
replay(Function, long, TimeUnit, Scheduler)210%n/a114411
replay(Function, long, TimeUnit, Scheduler, boolean)210%n/a114411
startWithArray(Object[])210%20%224411
window(long, long, int)210%n/a114411
window(Publisher, Function, int)210%n/a114411
concat(Publisher, Publisher)200%n/a113311
generate(Supplier, BiFunction, Consumer)200%n/a114411
just(Object, Object)200%n/a113311
blockingFirst(Object)200%20%225511
blockingLast(Object)200%20%225511
delay(long, TimeUnit, Scheduler, boolean)200%n/a113311
replay(int, long, TimeUnit, Scheduler)200%n/a114411
replay(int, long, TimeUnit, Scheduler, boolean)200%n/a114411
onBackpressureBuffer(int, boolean, boolean, Action)190%n/a113311
safeSubscribe(Subscriber)190%20%225511
sample(long, TimeUnit, Scheduler)190%n/a113311
sample(long, TimeUnit, Scheduler, boolean)190%n/a113311
subscribe(Subscriber)190%20%225511
throttleLatest(long, TimeUnit, Scheduler, boolean)190%n/a113311
blockingStream(int)190%n/a113311
timer(long, TimeUnit, Scheduler)180%n/a113311
unsafeCreate(Publisher)180%20%224411
zip(Iterable, Function)180%n/a113311
blockingFirst()180%20%226611
blockingLast()180%20%226611
debounce(long, TimeUnit, Scheduler)180%n/a113311
onBackpressureBuffer(long, Action, BackpressureOverflowStrategy)180%n/a113311
throttleFirst(long, TimeUnit, Scheduler)180%n/a113311
timeout0(long, TimeUnit, Publisher, Scheduler)180%n/a113311
fromPublisher(Publisher)170%20%224411
concatMapCompletable(Function, int)170%n/a113311
concatMapMaybe(Function, int)170%n/a113311
concatMapSingle(Function, int)170%n/a113311
flatMapCompletable(Function, boolean, int)170%n/a113311
flatMapIterable(Function, BiFunction)170%n/a113311
flatMapIterable(Function, BiFunction, int)170%n/a113311
flatMapMaybe(Function, boolean, int)170%n/a113311
flatMapSingle(Function, boolean, int)170%n/a113311
observeOn(Scheduler, boolean, int)170%n/a113311
publish(Function, int)170%n/a113311
startWithItem(Object)170%n/a112211
fromFuture(Future, long, TimeUnit)160%n/a113311
ambWith(Publisher)160%n/a112211
buffer(Publisher, Supplier)160%n/a113311
collect(Supplier, BiConsumer)160%n/a113311
concatMapIterable(Function, int)160%n/a113311
distinct(Function, Supplier)160%n/a113311
flatMapIterable(Function, int)160%n/a113311
onBackpressureReduce(Supplier, BiFunction)160%n/a113311
reduce(Object, BiFunction)160%n/a113311
reduceWith(Supplier, BiFunction)160%n/a113311
scanWith(Supplier, BiFunction)160%n/a113311
startWith(Publisher)160%n/a112211
timeInterval(TimeUnit, Scheduler)160%n/a113311
window(Publisher, int)160%n/a113311
withLatestFrom(Publisher, BiFunction)160%n/a113311
withLatestFrom(Publisher[], Function)160%n/a113311
withLatestFrom(Iterable, Function)160%n/a113311
zipWith(Iterable, BiFunction)160%n/a113311
concatMapStream(Function, int)160%n/a113311
flatMapStream(Function, int)160%n/a113311
create(FlowableOnSubscribe, BackpressureStrategy)150%n/a113311
onBackpressureBuffer(int, boolean, boolean)150%n/a112211
replay(Function, int)150%n/a113311
replay(Function, int, boolean)150%n/a113311
replay(long, TimeUnit, Scheduler)150%n/a113311
replay(long, TimeUnit, Scheduler, boolean)150%n/a113311
toMap(Function, Function)150%n/a113311
toMap(Function, Function, Supplier)150%n/a113311
doOnEach(Consumer)140%n/a115511
doOnEach(Subscriber)140%n/a115511
subscribeOn(Scheduler)140%20%222211
timeout(Publisher, Function, Publisher)140%n/a113311
timestamp(TimeUnit, Scheduler)140%n/a113311
test(long, boolean)140%20%225511
sorted(Comparator)130%n/a112211
startWithIterable(Iterable)130%n/a111111
timeout0(Publisher, Function, Publisher)130%n/a112211
toMultimap(Function)130%n/a114411
fromFuture(Future)120%n/a112211
distinctUntilChanged(Function)120%n/a112211
distinctUntilChanged(BiPredicate)120%n/a112211
sample(Publisher)120%n/a112211
sample(Publisher, boolean)120%n/a112211
subscribeOn(Scheduler, boolean)120%n/a112211
switchMapCompletable(Function)120%n/a112211
switchMapCompletableDelayError(Function)120%n/a112211
switchMapMaybe(Function)120%n/a112211
switchMapMaybeDelayError(Function)120%n/a112211
switchMapSingle(Function)120%n/a112211
switchMapSingleDelayError(Function)120%n/a112211
toList(int)120%n/a112211
amb(Iterable)110%n/a112211
concat(Iterable)110%n/a112211
all(Predicate)110%n/a112211
any(Predicate)110%n/a112211
cacheWithInitialCapacity(int)110%n/a112211
concatWith(SingleSource)110%n/a112211
concatWith(MaybeSource)110%n/a112211
concatWith(CompletableSource)110%n/a112211
debounce(Function)110%n/a112211
delaySubscription(Publisher)110%n/a112211
dematerialize(Function)110%n/a112211
doFinally(Action)110%n/a112211
doAfterNext(Consumer)110%n/a112211
filter(Predicate)110%n/a112211
last(Object)110%n/a112211
lift(FlowableOperator)110%n/a112211
map(Function)110%n/a112211
mergeWith(SingleSource)110%n/a112211
mergeWith(MaybeSource)110%n/a112211
mergeWith(CompletableSource)110%n/a112211
ofType(Class)110%n/a112211
onBackpressureDrop(Consumer)110%n/a112211
onBackpressureLatest(Consumer)110%n/a112211
onBackpressureReduce(BiFunction)110%n/a112211
onErrorComplete(Predicate)110%n/a112211
onErrorResumeNext(Function)110%n/a112211
onErrorReturn(Function)110%n/a112211
publish(int)110%n/a112211
reduce(BiFunction)110%n/a112211
repeatUntil(BooleanSupplier)110%n/a112211
repeatWhen(Function)110%n/a112211
retry(BiPredicate)110%n/a112211
retryWhen(Function)110%n/a112211
scan(BiFunction)110%n/a112211
single(Object)110%n/a112211
skipUntil(Publisher)110%n/a112211
skipWhile(Predicate)110%n/a112211
switchIfEmpty(Publisher)110%n/a112211
takeUntil(Predicate)110%n/a112211
takeUntil(Publisher)110%n/a112211
takeWhile(Predicate)110%n/a112211
timeout(long, TimeUnit, Publisher)110%n/a112211
timeout(long, TimeUnit, Scheduler, Publisher)110%n/a112211
toList(Supplier)110%n/a112211
toMultimap(Function, Function)110%n/a113311
toSortedList(Comparator, int)110%n/a112211
unsubscribeOn(Scheduler)110%n/a112211
fromOptional(Optional)110%n/a112211
mapOptional(Function)110%n/a112211
collect(Collector)110%n/a112211
defer(Supplier)100%n/a112211
error(Supplier)100%n/a112211
fromAction(Action)100%n/a112211
fromCallable(Callable)100%n/a112211
fromCompletable(CompletableSource)100%n/a112211
fromIterable(Iterable)100%n/a112211
fromMaybe(MaybeSource)100%n/a112211
fromRunnable(Runnable)100%n/a112211
fromSingle(SingleSource)100%n/a112211
fromSupplier(Supplier)100%n/a112211
generate(Consumer)100%n/a114411
generate(Supplier, BiConsumer)100%n/a113311
generate(Supplier, BiConsumer, Consumer)100%n/a112211
just(Object)100%n/a112211
blockingIterable(int)100%n/a112211
blockingMostRecent(Object)100%n/a112211
buffer(Publisher, int)100%n/a112211
collectInto(Object, BiConsumer)100%n/a112211
retryUntil(BooleanSupplier)100%n/a112211
scan(Object, BiFunction)100%n/a112211
startWith(CompletableSource)100%n/a112211
startWith(SingleSource)100%n/a112211
startWith(MaybeSource)100%n/a112211
timeout(Function, Publisher)100%n/a112211
timeout(Publisher, Function)100%n/a112211
toMap(Function)100%n/a112211
toSortedList(Comparator)100%n/a112211
test(long)100%n/a113311
fromCompletionStage(CompletionStage)100%n/a112211
fromStream(Stream)100%n/a112211
concatDelayError(Iterable)90%n/a112211
buffer(long, TimeUnit, Scheduler, int)90%n/a111111
buffer(long, TimeUnit, Scheduler)90%n/a111111
cast(Class)90%n/a112211
contains(Object)90%n/a112211
defaultIfEmpty(Object)90%n/a112211
delay(Function)90%n/a112211
onErrorResumeWith(Publisher)90%n/a112211
onErrorReturnItem(Object)90%n/a112211
replay(Function)90%n/a112211
replay(int)90%n/a112211
replay(int, boolean)90%n/a112211
sorted()90%n/a111111
takeLast(long, long, TimeUnit)90%n/a111111
takeLast(long, long, TimeUnit, Scheduler)90%n/a111111
takeLast(long, TimeUnit, Scheduler, boolean, int)90%n/a111111
window(long, TimeUnit, Scheduler, long, boolean)90%n/a111111
zipWith(Publisher, BiFunction)90%n/a112211
test()90%n/a113311
firstStage(Object)90%n/a111111
singleStage(Object)90%n/a111111
lastStage(Object)90%n/a111111
firstOrErrorStage()90%n/a111111
singleOrErrorStage()90%n/a111111
lastOrErrorStage()90%n/a111111
concatArrayEagerDelayError(int, int, Publisher[])80%n/a111111
error(Throwable)80%n/a112211
intervalRange(long, long, long, long, TimeUnit)80%n/a111111
merge(Iterable, int, int)80%n/a111111
mergeArray(int, int, Publisher[])80%n/a111111
mergeDelayError(Iterable, int, int)80%n/a111111
mergeArrayDelayError(int, int, Publisher[])80%n/a111111
mergeArrayDelayError(Publisher[])80%n/a111111
blockingSubscribe(Subscriber)80%n/a113311
buffer(long, long, TimeUnit)80%n/a111111
buffer(long, long, TimeUnit, Scheduler)80%n/a111111
compose(FlowableTransformer)80%n/a111111
concatWith(Publisher)80%n/a112211
doOnTerminate(Action)80%n/a111111
flatMap(Function, BiFunction)80%n/a111111
flatMap(Function, BiFunction, boolean)80%n/a111111
flatMap(Function, BiFunction, boolean, int)80%n/a111111
flatMap(Function, BiFunction, int)80%n/a111111
mergeWith(Publisher)80%n/a112211
replay(Function, int, long, TimeUnit)80%n/a111111
skipLast(long, TimeUnit)80%n/a111111
skipLast(long, TimeUnit, boolean)80%n/a111111
skipLast(long, TimeUnit, Scheduler)80%n/a111111
skipLast(long, TimeUnit, Scheduler, boolean)80%n/a111111
takeLast(long, TimeUnit)80%n/a111111
takeLast(long, TimeUnit, boolean)80%n/a111111
takeLast(long, TimeUnit, Scheduler)80%n/a111111
takeLast(long, TimeUnit, Scheduler, boolean)80%n/a111111
throttleLast(long, TimeUnit, Scheduler, Consumer)80%n/a111111
window(long, long, TimeUnit)80%n/a111111
window(long, long, TimeUnit, Scheduler)80%n/a111111
window(long, TimeUnit)80%n/a111111
window(long, TimeUnit, long)80%n/a111111
window(long, TimeUnit, long, boolean)80%n/a111111
window(long, TimeUnit, Scheduler)80%n/a111111
window(long, TimeUnit, Scheduler, long)80%n/a111111
static {...}80%n/a112211
concatDelayError(Publisher, int, boolean)70%n/a111111
mergeArray(Publisher[])70%n/a111111
mergeDelayError(Iterable, int)70%n/a111111
mergeDelayError(Publisher, int)70%n/a111111
toFuture()70%n/a111111
blockingSubscribe(Consumer, int)70%n/a112211
blockingSubscribe(Consumer, Consumer, int)70%n/a112211
blockingSubscribe(Consumer, Consumer, Action, int)70%n/a112211
buffer(long, TimeUnit)70%n/a111111
buffer(long, TimeUnit, int)70%n/a111111
concatMapEagerDelayError(Function, boolean)70%n/a111111
delay(long, TimeUnit)70%n/a111111
delay(long, TimeUnit, boolean)70%n/a111111
delay(long, TimeUnit, Scheduler)70%n/a111111
delaySubscription(long, TimeUnit, Scheduler)70%n/a111111
doAfterTerminate(Action)70%n/a111111
doOnComplete(Action)70%n/a111111
doOnError(Consumer)70%n/a111111
doOnNext(Consumer)70%n/a111111
flatMap(Function)70%n/a111111
flatMap(Function, boolean)70%n/a111111
flatMap(Function, int)70%n/a111111
flatMap(Function, boolean, int)70%n/a111111
groupBy(Function)70%n/a111111
groupBy(Function, boolean)70%n/a111111
groupBy(Function, Function)70%n/a111111
groupBy(Function, Function, boolean)70%n/a111111
lastOrError()70%n/a111111
onBackpressureBuffer(int, Action)70%n/a111111
onBackpressureLatest()70%n/a111111
replay(Function, long, TimeUnit)70%n/a111111
replay(int, long, TimeUnit)70%n/a111111
sample(long, TimeUnit, boolean)70%n/a111111
singleOrError()70%n/a111111
skip(long, TimeUnit, Scheduler)70%n/a111111
take(long, TimeUnit, Scheduler)70%n/a111111
throttleLatest(long, TimeUnit)70%n/a111111
throttleLatest(long, TimeUnit, boolean)70%n/a111111
throttleLatest(long, TimeUnit, Scheduler)70%n/a111111
throttleWithTimeout(long, TimeUnit, Scheduler, Consumer)70%n/a111111
timeout(long, TimeUnit)70%n/a111111
timeout(long, TimeUnit, Scheduler)70%n/a111111
to(FlowableConverter)70%n/a111111
toMultimap(Function, Function, Supplier)70%n/a111111
zipWith(Publisher, BiFunction, boolean, int)70%n/a111111
concat(Publisher, int)60%n/a111111
interval(long, long, TimeUnit)60%n/a111111
interval(long, TimeUnit)60%n/a111111
interval(long, TimeUnit, Scheduler)60%n/a111111
merge(Iterable, int)60%n/a111111
merge(Publisher, int)60%n/a111111
mergeDelayError(Iterable)60%n/a111111
sequenceEqual(Publisher, Publisher)60%n/a111111
sequenceEqual(Publisher, Publisher, BiPredicate)60%n/a111111
sequenceEqual(Publisher, Publisher, int)60%n/a111111
switchOnNext(Publisher, int)60%n/a111111
switchOnNextDelayError(Publisher, int)60%n/a111111
using(Supplier, Function, Consumer)60%n/a111111
blockingSubscribe(Consumer)60%n/a112211
blockingSubscribe(Consumer, Consumer)60%n/a112211
blockingSubscribe(Consumer, Consumer, Action)60%n/a112211
buffer(int, int)60%n/a111111
buffer(int, Supplier)60%n/a111111
buffer(Publisher, Function)60%n/a111111
concatMapCompletableDelayError(Function)60%n/a111111
concatMapCompletableDelayError(Function, boolean)60%n/a111111
concatMapDelayError(Function)60%n/a111111
concatMapEager(Function)60%n/a111111
concatMapMaybeDelayError(Function)60%n/a111111
concatMapMaybeDelayError(Function, boolean)60%n/a111111
concatMapSingleDelayError(Function)60%n/a111111
concatMapSingleDelayError(Function, boolean)60%n/a111111
count()60%n/a111111
debounce(long, TimeUnit)60%n/a111111
delay(Publisher, Function)60%n/a111111
delaySubscription(long, TimeUnit)60%n/a111111
doOnCancel(Action)60%n/a111111
doOnRequest(LongConsumer)60%n/a111111
doOnSubscribe(Consumer)60%n/a111111
flatMapCompletable(Function)60%n/a111111
flatMapMaybe(Function)60%n/a111111
flatMapSingle(Function)60%n/a111111
forEachWhile(Predicate)60%n/a111111
forEachWhile(Predicate, Consumer)60%n/a111111
hide()60%n/a111111
ignoreElements()60%n/a111111
lastElement()60%n/a111111
materialize()60%n/a111111
observeOn(Scheduler)60%n/a111111
observeOn(Scheduler, boolean)60%n/a111111
onBackpressureBuffer()60%n/a111111
onBackpressureBuffer(boolean)60%n/a111111
onBackpressureBuffer(int)60%n/a111111
onBackpressureBuffer(int, boolean)60%n/a111111
onBackpressureDrop()60%n/a111111
onTerminateDetach()60%n/a111111
rebatchRequests(int)60%n/a111111
replay(long, TimeUnit)60%n/a111111
sample(long, TimeUnit)60%n/a111111
serialize()60%n/a111111
singleElement()60%n/a111111
skip(long, TimeUnit)60%n/a111111
subscribe()60%n/a111111
subscribe(Consumer)60%n/a111111
subscribe(Consumer, Consumer)60%n/a111111
switchMap(Function, int)60%n/a111111
switchMapDelayError(Function, int)60%n/a111111
take(long, TimeUnit)60%n/a111111
throttleFirst(long, TimeUnit)60%n/a111111
throttleLast(long, TimeUnit, Scheduler)60%n/a111111
throttleWithTimeout(long, TimeUnit, Scheduler)60%n/a111111
timeout(Function)60%n/a111111
toList()60%n/a111111
toObservable()60%n/a111111
window(long)60%n/a111111
window(long, long)60%n/a111111
window(Publisher, Function)60%n/a111111
zipWith(Publisher, BiFunction, boolean)60%n/a111111
combineLatestArray(Publisher[], Function)50%n/a111111
combineLatest(Iterable, Function)50%n/a111111
combineLatestArrayDelayError(Publisher[], Function)50%n/a111111
combineLatestDelayError(Iterable, Function)50%n/a111111
concatArrayEager(Publisher[])50%n/a111111
concatArrayEagerDelayError(Publisher[])50%n/a111111
concatDelayError(Publisher)50%n/a111111
concatEager(Iterable)50%n/a111111
concatEager(Publisher)50%n/a111111
concatEagerDelayError(Iterable)50%n/a111111
concatEagerDelayError(Publisher)50%n/a111111
generate(Supplier, BiFunction)50%n/a111111
merge(Iterable)50%n/a111111
switchOnNext(Publisher)50%n/a111111
timer(long, TimeUnit)50%n/a111111
blockingForEach(Consumer)50%n/a112211
blockingLatest()50%n/a111111
blockingNext()50%n/a111111
blockingSingle(Object)50%n/a111111
buffer(int)50%n/a111111
buffer(Publisher)50%n/a111111
concatMap(Function)50%n/a111111
concatMapCompletable(Function)50%n/a111111
concatMapIterable(Function)50%n/a111111
concatMapMaybe(Function)50%n/a111111
concatMapSingle(Function)50%n/a111111
distinct()50%n/a111111
distinct(Function)50%n/a111111
first(Object)50%n/a111111
flatMapIterable(Function)50%n/a111111
parallel(int, int)50%n/a111111
publish(Function)50%n/a111111
retry()50%n/a111111
retry(long)50%n/a111111
retry(Predicate)50%n/a111111
subscribeWith(Subscriber)50%n/a112211
switchMap(Function)50%n/a111111
switchMapDelayError(Function)50%n/a111111
throttleLast(long, TimeUnit)50%n/a111111
throttleWithTimeout(long, TimeUnit)50%n/a111111
timeInterval()50%n/a111111
timeInterval(Scheduler)50%n/a111111
timeInterval(TimeUnit)50%n/a111111
timestamp()50%n/a111111
timestamp(Scheduler)50%n/a111111
timestamp(TimeUnit)50%n/a111111
toSortedList(int)50%n/a111111
window(Publisher)50%n/a111111
concatMapStream(Function)50%n/a111111
flatMapStream(Function)50%n/a111111
concat(Publisher)40%n/a111111
merge(Publisher)40%n/a111111
mergeDelayError(Publisher)40%n/a111111
switchOnNextDelayError(Publisher)40%n/a111111
blockingIterable()40%n/a111111
blockingSingle()40%n/a111111
cache()40%n/a111111
distinctUntilChanged()40%n/a111111
firstElement()40%n/a111111
firstOrError()40%n/a111111
forEach(Consumer)40%n/a111111
isEmpty()40%n/a111111
onErrorComplete()40%n/a111111
parallel(int)40%n/a111111
publish()40%n/a111111
repeat()40%n/a111111
share()40%n/a111111
toSortedList()40%n/a111111
blockingStream()40%n/a111111
Flowable()30%n/a111111
empty()30%n/a111111
never()30%n/a111111
blockingSubscribe()30%n/a112211
parallel()30%n/a111111
replay()30%n/a111111
bufferSize()20%n/a111111