Observable

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total7,292 of 7,3220%139 of 1390%5695721,2821,291498501
just(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object)840%n/a11111111
zip(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function9)840%n/a11111111
combineLatest(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function9)830%n/a11111111
just(Object, Object, Object, Object, Object, Object, Object, Object, Object)760%n/a11101011
zip(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function8)760%n/a11101011
combineLatest(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, 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(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function7)680%n/a119911
combineLatest(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function7)670%n/a119911
just(Object, Object, Object, Object, Object, Object, Object)600%n/a118811
zip(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function6)600%n/a118811
combineLatest(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function6)590%n/a118811
rangeLong(long, long)560%100%66101011
just(Object, Object, Object, Object, Object, Object)520%n/a117711
zip(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function5)520%n/a117711
combineLatest(ObservableSource, ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function5)510%n/a117711
range(int, int)470%80%559911
withLatestFrom(ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function5)450%n/a117711
just(Object, Object, Object, Object, Object)440%n/a116611
zip(ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function4)440%n/a116611
combineLatest(ObservableSource, ObservableSource, ObservableSource, ObservableSource, Function4)430%n/a116611
merge(ObservableSource, ObservableSource, ObservableSource, ObservableSource)400%n/a115511
mergeDelayError(ObservableSource, ObservableSource, ObservableSource, ObservableSource)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(ObservableSource, ObservableSource, ObservableSource, Function4)370%n/a116611
concat(ObservableSource, ObservableSource, ObservableSource, ObservableSource)360%n/a115511
just(Object, Object, Object, Object)360%n/a115511
zip(ObservableSource, ObservableSource, ObservableSource, Function3)360%n/a115511
concatMapDelayError(Function, boolean, int)360%60%448811
combineLatest(ObservableSource, ObservableSource, ObservableSource, Function3)350%n/a115511
subscribe(Consumer, Consumer, Action, DisposableContainer)330%n/a118811
window(long, long, TimeUnit, Scheduler, int)330%n/a116611
merge(ObservableSource, ObservableSource, ObservableSource)320%n/a114411
mergeDelayError(ObservableSource, ObservableSource, ObservableSource)320%n/a114411
concatMap(Function, int)320%40%338811
switchMap(Function, int)320%40%338811
switchMapDelayError(Function, int)320%40%338811
combineLatestArray(ObservableSource[], Function, int)310%20%227711
combineLatestArrayDelayError(ObservableSource[], Function, int)310%20%227711
toFlowable(BackpressureStrategy)310%50%558811
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(ObservableSource, ObservableSource, Function3)290%n/a115511
concat(ObservableSource, ObservableSource, ObservableSource)280%n/a114411
concatArray(ObservableSource[])280%40%336611
just(Object, Object, Object)280%n/a114411
zip(ObservableSource, ObservableSource, BiFunction)280%n/a114411
zip(ObservableSource, ObservableSource, BiFunction, boolean)280%n/a114411
zip(ObservableSource, ObservableSource, BiFunction, boolean, int)280%n/a114411
elementAt(long, Object)280%20%224411
retry(long, Predicate)280%20%224411
combineLatest(ObservableSource, ObservableSource, BiFunction)270%n/a114411
zipArray(Function, boolean, int, ObservableSource[])270%20%226611
blockingForEach(Consumer, int)270%20%22101011
skipLast(long, TimeUnit, Scheduler, boolean, int)270%n/a115511
ambArray(ObservableSource[])260%40%337711
combineLatest(Iterable, Function, int)260%n/a115511
combineLatestDelayError(Iterable, Function, int)260%n/a115511
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(ObservableSource, Function, Function, BiFunction)260%n/a115511
join(ObservableSource, 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
sequenceEqual(ObservableSource, ObservableSource, BiPredicate, int)250%n/a115511
buffer(long, long, TimeUnit, Scheduler, Supplier)250%n/a114411
subscribe(Consumer, Consumer, Action)250%n/a116611
concatArrayDelayError(ObservableSource[])240%40%337711
fromArray(Object[])240%40%336611
merge(ObservableSource, ObservableSource)240%n/a113311
mergeDelayError(ObservableSource, ObservableSource)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
sample(long, TimeUnit, Scheduler, boolean, Consumer)230%n/a114411
take(long)230%20%223311
throttleLatest(long, TimeUnit, Scheduler, boolean, Consumer)230%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
groupBy(Function, Function, boolean, int)220%n/a114411
throttleFirst(long, TimeUnit, Scheduler, Consumer)220%n/a114411
concatDelayError(ObservableSource, int, boolean)210%20%223311
interval(long, long, TimeUnit, Scheduler)210%n/a113311
using(Supplier, Function, Consumer, boolean)210%n/a114411
buffer(int, int, Supplier)210%n/a114411
buffer(ObservableSource, 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
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(ObservableSource, Function, int)210%n/a114411
concat(ObservableSource, ObservableSource)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
replay(int, long, TimeUnit, Scheduler)200%n/a114411
replay(int, long, TimeUnit, Scheduler, boolean)200%n/a114411
subscribe(Observer)191747%n/a0181401
sample(long, TimeUnit, Scheduler)190%n/a113311
sample(long, TimeUnit, Scheduler, boolean)190%n/a113311
throttleLatest(long, TimeUnit, Scheduler, boolean)190%n/a113311
toMap(Function, Function, Supplier)190%n/a114411
blockingStream(int)190%n/a113311
merge(ObservableSource, int)180%n/a113311
mergeDelayError(ObservableSource, int)180%n/a113311
timer(long, TimeUnit, Scheduler)180%n/a113311
unsafeCreate(ObservableSource)180%20%224411
zip(Iterable, Function)180%n/a113311
blockingFirst()180%20%226611
blockingLast()180%20%226611
debounce(long, TimeUnit, Scheduler)180%n/a113311
delay(long, TimeUnit, Scheduler, boolean)180%n/a113311
safeSubscribe(Observer)180%20%225511
throttleFirst(long, TimeUnit, Scheduler)180%n/a113311
timeout0(long, TimeUnit, ObservableSource, Scheduler)180%n/a113311
concat(ObservableSource, int)170%n/a113311
switchOnNext(ObservableSource, int)170%n/a113311
switchOnNextDelayError(ObservableSource, int)170%n/a113311
wrap(ObservableSource)170%20%224411
concatMapCompletable(Function, int)170%n/a113311
concatMapMaybe(Function, int)170%n/a113311
concatMapSingle(Function, int)170%n/a113311
flatMap(Function, BiFunction, boolean, int, int)170%n/a113311
flatMapIterable(Function, BiFunction)170%n/a113311
observeOn(Scheduler, boolean, int)170%n/a113311
fromFuture(Future, long, TimeUnit)160%n/a113311
ambWith(ObservableSource)160%n/a112211
buffer(ObservableSource, Supplier)160%n/a113311
collect(Supplier, BiConsumer)160%n/a113311
distinct(Function, Supplier)160%n/a113311
doOnLifecycle(Consumer, Action)160%n/a113311
reduce(Object, BiFunction)160%n/a113311
reduceWith(Supplier, BiFunction)160%n/a113311
scanWith(Supplier, BiFunction)160%n/a113311
startWith(ObservableSource)160%n/a112211
timeInterval(TimeUnit, Scheduler)160%n/a113311
window(ObservableSource, int)160%n/a113311
withLatestFrom(ObservableSource, BiFunction)160%n/a113311
withLatestFrom(ObservableSource[], Function)160%n/a113311
withLatestFrom(Iterable, Function)160%n/a113311
zipWith(Iterable, BiFunction)160%n/a113311
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
merge(ObservableSource)140%n/a112211
mergeDelayError(ObservableSource)140%n/a112211
doOnEach(Consumer)140%n/a115511
doOnEach(Observer)140%n/a115511
timeout(ObservableSource, Function, ObservableSource)140%n/a113311
timestamp(TimeUnit, Scheduler)140%n/a113311
sorted(Comparator)130%n/a112211
startWithIterable(Iterable)130%n/a111111
startWithItem(Object)130%n/a111111
timeout0(ObservableSource, Function, ObservableSource)130%n/a112211
toMultimap(Function)130%n/a114411
test(boolean)130%20%225511
fromFuture(Future)120%n/a112211
blockingSingle()120%20%224411
distinctUntilChanged(Function)120%n/a112211
distinctUntilChanged(BiPredicate)120%n/a112211
doOnTerminate(Action)120%n/a113311
flatMapCompletable(Function, boolean)120%n/a112211
flatMapMaybe(Function, boolean)120%n/a112211
flatMapSingle(Function, boolean)120%n/a112211
sample(ObservableSource)120%n/a112211
sample(ObservableSource, 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
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
concatMapIterable(Function)110%n/a112211
concatWith(SingleSource)110%n/a112211
concatWith(MaybeSource)110%n/a112211
concatWith(CompletableSource)110%n/a112211
debounce(Function)110%n/a112211
delaySubscription(ObservableSource)110%n/a112211
dematerialize(Function)110%n/a112211
doAfterNext(Consumer)110%n/a112211
doAfterTerminate(Action)110%n/a112211
doFinally(Action)110%n/a112211
filter(Predicate)110%n/a112211
flatMapIterable(Function)110%n/a112211
last(Object)110%n/a112211
lift(ObservableOperator)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
onErrorComplete(Predicate)110%n/a112211
onErrorResumeNext(Function)110%n/a112211
onErrorReturn(Function)110%n/a112211
publish(Function)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(ObservableSource)110%n/a112211
skipWhile(Predicate)110%n/a112211
subscribeOn(Scheduler)110%n/a112211
switchIfEmpty(ObservableSource)110%n/a112211
takeUntil(ObservableSource)110%n/a112211
takeUntil(Predicate)110%n/a112211
takeWhile(Predicate)110%n/a112211
timeout(long, TimeUnit, ObservableSource)110%n/a112211
timeout(long, TimeUnit, Scheduler, ObservableSource)110%n/a112211
toList(int)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
flatMapStream(Function)110%n/a112211
create(ObservableOnSubscribe)100%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
fromMaybe(MaybeSource)100%n/a112211
fromPublisher(Publisher)100%n/a112211
fromRunnable(Runnable)100%n/a112211
fromSingle(SingleSource)100%n/a112211
fromSupplier(Supplier)100%n/a112211
generate(Consumer)100%n/a113311
generate(Supplier, BiConsumer)100%n/a112211
generate(Supplier, BiConsumer, Consumer)100%n/a112211
just(Object)100%n/a112211
blockingIterable(int)100%n/a112211
blockingMostRecent(Object)100%n/a112211
buffer(ObservableSource, 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, ObservableSource)100%n/a112211
timeout(ObservableSource, Function)100%n/a112211
toMap(Function)100%n/a112211
toSortedList(Comparator)100%n/a112211
fromCompletionStage(CompletionStage)100%n/a112211
fromStream(Stream)100%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(ObservableSource)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(ObservableSource, 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
concatArrayEager(int, int, ObservableSource[])80%n/a111111
concatArrayEagerDelayError(int, int, ObservableSource[])80%n/a111111
concatDelayError(Iterable)80%n/a112211
concatEager(Iterable, int, int)80%n/a111111
concatEagerDelayError(Iterable, int, int)80%n/a111111
concatEagerDelayError(ObservableSource, int, int)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, ObservableSource[])80%n/a111111
mergeDelayError(Iterable, int, int)80%n/a111111
mergeArrayDelayError(int, int, ObservableSource[])80%n/a111111
mergeArrayDelayError(ObservableSource[])80%n/a111111
blockingSubscribe(Observer)80%n/a113311
buffer(long, long, TimeUnit)80%n/a111111
buffer(long, long, TimeUnit, Scheduler)80%n/a111111
compose(ObservableTransformer)80%n/a111111
concatWith(ObservableSource)80%n/a112211
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(ObservableSource)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
concatEager(ObservableSource, int, int)70%n/a111111
mergeArray(ObservableSource[])70%n/a111111
mergeDelayError(Iterable, int)70%n/a111111
toFuture()70%n/a111111
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
doOnComplete(Action)70%n/a111111
doOnError(Consumer)70%n/a111111
doOnNext(Consumer)70%n/a111111
flatMap(Function, boolean, int)70%n/a111111
flatMap(Function, 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
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(ObservableConverter)70%n/a111111
toMultimap(Function, Function, Supplier)70%n/a111111
zipWith(ObservableSource, BiFunction, boolean, int)70%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
mergeDelayError(Iterable)60%n/a111111
sequenceEqual(ObservableSource, ObservableSource)60%n/a111111
sequenceEqual(ObservableSource, ObservableSource, BiPredicate)60%n/a111111
sequenceEqual(ObservableSource, ObservableSource, 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(ObservableSource, Function)60%n/a111111
concatMapDelayError(Function)60%n/a111111
concatMapEager(Function)60%n/a111111
concatMapCompletableDelayError(Function)60%n/a111111
concatMapCompletableDelayError(Function, boolean)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(ObservableSource, Function)60%n/a111111
delaySubscription(long, TimeUnit)60%n/a111111
flatMap(Function, boolean)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
onTerminateDetach()60%n/a111111
publish()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
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
window(long)60%n/a111111
window(long, long)60%n/a111111
window(ObservableSource, Function)60%n/a111111
zipWith(ObservableSource, BiFunction, boolean)60%n/a111111
combineLatest(Iterable, Function)50%n/a111111
combineLatestArray(ObservableSource[], Function)50%n/a111111
combineLatestArrayDelayError(ObservableSource[], Function)50%n/a111111
combineLatestDelayError(Iterable, Function)50%n/a111111
concatArrayEager(ObservableSource[])50%n/a111111
concatArrayEagerDelayError(ObservableSource[])50%n/a111111
concatDelayError(ObservableSource)50%n/a111111
concatEager(Iterable)50%n/a111111
concatEager(ObservableSource)50%n/a111111
concatEagerDelayError(Iterable)50%n/a111111
concatEagerDelayError(ObservableSource)50%n/a111111
generate(Supplier, BiFunction)50%n/a111111
merge(Iterable)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(ObservableSource)50%n/a111111
concatMap(Function)50%n/a111111
concatMapCompletable(Function)50%n/a111111
concatMapMaybe(Function)50%n/a111111
concatMapSingle(Function)50%n/a111111
distinct()50%n/a111111
distinct(Function)50%n/a111111
doOnDispose(Action)50%n/a111111
doOnSubscribe(Consumer)50%n/a111111
first(Object)50%n/a111111
flatMap(Function)50%n/a111111
flatMapCompletable(Function)50%n/a111111
flatMapMaybe(Function)50%n/a111111
flatMapSingle(Function)50%n/a111111
retry()50%n/a111111
retry(long)50%n/a111111
retry(Predicate)50%n/a111111
subscribeWith(Observer)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(ObservableSource)50%n/a111111
concat(ObservableSource)40%n/a111111
switchOnNext(ObservableSource)40%n/a111111
switchOnNextDelayError(ObservableSource)40%n/a111111
blockingIterable()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
repeat()40%n/a111111
share()40%n/a111111
toList()40%n/a111111
toSortedList()40%n/a111111
blockingStream()40%n/a111111
concatMapStream(Function)40%n/a111111
empty()30%n/a111111
never()30%n/a111111
blockingSubscribe()30%n/a112211
replay()30%n/a111111
bufferSize()20%n/a111111
fromIterable(Iterable)10100%n/a010201
Observable()3100%n/a010101