Observable

Source file "rx/Observable.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total4,331 of 4,3310%88 of 880%453453563563409409
subscribe(Subscriber, Observable)750%80%55212111
just(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object)450%n/a111111
zip(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Func9)450%n/a111111
unsafeSubscribe(Subscriber)450%n/a11131311
combineLatest(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Func9)430%n/a111111
withLatestFrom(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Func9)430%n/a112211
just(Object, Object, Object, Object, Object, Object, Object, Object, Object)410%n/a111111
range(int, int)410%80%559911
zip(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Func8)410%n/a111111
concatEager(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)410%n/a111111
merge(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)400%n/a111111
combineLatest(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Func8)390%n/a111111
concatMapEager(Func1, int, int)390%40%335511
withLatestFrom(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Func8)390%n/a112211
just(Object, Object, Object, Object, Object, Object, Object, Object)370%n/a111111
zip(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Func7)370%n/a111111
concatEager(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)370%n/a111111
merge(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)360%n/a111111
window(int, int)360%40%335511
combineLatest(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Func7)350%n/a111111
withLatestFrom(Observable, Observable, Observable, Observable, Observable, Observable, Func7)350%n/a112211
just(Object, Object, Object, Object, Object, Object, Object)330%n/a111111
zip(Observable, Observable, Observable, Observable, Observable, Observable, Func6)330%n/a111111
concatEager(Observable, Observable, Observable, Observable, Observable, Observable, Observable)330%n/a111111
merge(Observable, Observable, Observable, Observable, Observable, Observable, Observable)320%n/a111111
combineLatest(Observable, Observable, Observable, Observable, Observable, Observable, Func6)310%n/a111111
zip(Iterable, FuncN)310%20%225511
withLatestFrom(Observable, Observable, Observable, Observable, Observable, Func6)310%n/a112211
subscribe(Action1, Action1, Action0)300%60%447711
just(Object, Object, Object, Object, Object, Object)290%n/a111111
zip(Observable, Observable, Observable, Observable, Observable, Func5)290%n/a111111
concatEager(Observable, Observable, Observable, Observable, Observable, Observable)290%n/a111111
merge(Observable, Observable, Observable, Observable, Observable, Observable)280%n/a111111
combineLatest(Observable, Observable, Observable, Observable, Observable, Func5)270%n/a111111
withLatestFrom(Observable, Observable, Observable, Observable, Func5)270%n/a112211
just(Object, Object, Object, Object, Object)250%n/a111111
zip(Observable, Observable, Observable, Observable, Func4)250%n/a111111
concatEager(Observable, Observable, Observable, Observable, Observable)250%n/a111111
subscribe(Action1, Action1)250%40%336611
merge(Observable, Observable, Observable, Observable, Observable)240%n/a111111
concatMapEager(Func1, int)240%20%223311
combineLatest(Observable, Observable, Observable, Observable, Func4)230%n/a111111
withLatestFrom(Observable, Observable, Observable, Func4)230%n/a112211
subscribe(Observer)220%40%335511
from(Object[])210%40%336611
just(Object, Object, Object, Object)210%n/a111111
zip(Observable, Observable, Observable, Func3)210%n/a111111
concatEager(Observable, Observable, Observable, Observable)210%n/a111111
takeLast(int)210%40%335511
timeout(Func0, Func1, Observable)210%40%334411
merge(Observable, Observable, Observable, Observable)200%n/a111111
subscribe(Action1)200%20%225511
combineLatest(Observable, Observable, Observable, Func3)190%n/a111111
concatMap(Func1)190%20%224411
concatMapDelayError(Func1)190%20%224411
doOnTerminate(Action0)190%n/a114411
rebatchRequests(int)190%20%223311
withLatestFrom(Observable, Observable, Func3)190%n/a111111
doOnCompleted(Action0)180%n/a114411
doOnError(Action1)180%n/a114411
doOnNext(Action1)180%n/a114411
groupBy(Func1, Func1, int, boolean, Func1)180%20%223311
just(Object, Object, Object)170%n/a111111
zip(Observable, Observable, Func2)170%n/a111111
concatEager(Observable, Observable, Observable)170%n/a111111
observeOn(Scheduler, boolean, int)170%20%223311
merge(Observable, Observable, Observable)160%n/a111111
groupBy(Func1, Func1, Func1)160%20%223311
replay(Func1, int, long, TimeUnit, Scheduler)160%20%224411
subscribeOn(Scheduler, boolean)160%20%223311
combineLatest(Observable, Observable, Func2)150%n/a111111
merge(Observable, int)150%20%223311
flatMap(Func1, int)150%20%223311
subscribe()150%n/a114411
merge(Observable)140%20%223311
switchIfEmpty(Observable)140%20%223311
flatMap(Func1)140%20%223311
replay(int, long, TimeUnit, Scheduler)140%20%223311
just(Object, Object)130%n/a111111
delaySubscription(Observable)130%20%223311
concatEager(Observable, Observable)130%n/a111111
startWith(Object, Object, Object, Object, Object, Object, Object, Object, Object)130%n/a111111
amb(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)120%n/a111111
concat(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)120%n/a111111
concatDelayError(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)120%n/a111111
merge(Observable, Observable)120%n/a111111
mergeDelayError(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)120%n/a111111
doOnEach(Action1)120%n/a112211
startWith(Object, Object, Object, Object, Object, Object, Object, Object)120%n/a111111
amb(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)110%n/a111111
concat(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)110%n/a111111
concatDelayError(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)110%n/a111111
mergeDelayError(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)110%n/a111111
buffer(long, long, TimeUnit, Scheduler)110%n/a111111
buffer(long, TimeUnit, int)110%n/a111111
buffer(long, TimeUnit, int, Scheduler)110%n/a111111
startWith(Object, Object, Object, Object, Object, Object, Object)110%n/a111111
subscribeOn(Scheduler)110%20%221111
window(long, long, TimeUnit, int, Scheduler)110%n/a111111
amb(Observable, Observable, Observable, Observable, Observable, Observable, Observable)100%n/a111111
combineLatestDelayError(Iterable, FuncN)100%n/a111111
concat(Observable, Observable, Observable, Observable, Observable, Observable, Observable)100%n/a111111
concatDelayError(Observable, Observable, Observable, Observable, Observable, Observable, Observable)100%n/a111111
mergeDelayError(Observable, Observable, Observable, Observable, Observable, Observable, Observable)100%n/a111111
zip(Observable, FuncN)100%n/a111111
delay(Func0, Func1)100%n/a111111
flatMap(Func1, Func2, int)100%n/a111111
groupJoin(Observable, Func1, Func1, Func2)100%n/a111111
join(Observable, Func1, Func1, Func2)100%n/a111111
startWith(Object, Object, Object, Object, Object, Object)100%n/a111111
takeLast(int, long, TimeUnit, Scheduler)100%n/a111111
timeout(long, TimeUnit, Observable, Scheduler)100%n/a111111
toMultimap(Func1, Func1, Func0, Func1)100%n/a111111
amb(Observable, Observable, Observable, Observable, Observable, Observable)90%n/a111111
concat(Observable, Observable, Observable, Observable, Observable, Observable)90%n/a111111
concatDelayError(Observable, Observable, Observable, Observable, Observable, Observable)90%n/a111111
interval(long, long, TimeUnit, Scheduler)90%n/a111111
mergeDelayError(Observable, Observable, Observable, Observable, Observable, Observable)90%n/a111111
using(Func0, Func1, Action1, boolean)90%n/a111111
debounce(long, TimeUnit, Scheduler)90%n/a111111
delay(long, TimeUnit, Scheduler)90%n/a111111
delaySubscription(long, TimeUnit, Scheduler)90%n/a111111
flatMap(Func1, Func2)90%n/a111111
flatMapCompletable(Func1, boolean, int)90%n/a111111
flatMapSingle(Func1, boolean, int)90%n/a111111
mapNotification(Func1, Func1, Func0)90%n/a111111
onBackpressureBuffer(long, Action0, BackpressureOverflow.Strategy)90%n/a111111
sample(long, TimeUnit, Scheduler)90%n/a111111
skip(long, TimeUnit, Scheduler)90%n/a111111
skipLast(long, TimeUnit, Scheduler)90%n/a111111
startWith(Object, Object, Object, Object, Object)90%n/a111111
take(long, TimeUnit, Scheduler)90%n/a111111
takeLast(long, TimeUnit, Scheduler)90%n/a111111
throttleFirst(long, TimeUnit, Scheduler)90%n/a111111
toMap(Func1, Func1, Func0)90%n/a111111
toMultimap(Func1, Func1, Func0)90%n/a111111
withLatestFrom(Observable[], FuncN)90%n/a111111
withLatestFrom(Iterable, FuncN)90%n/a111111
test()90%n/a113311
test(long)90%n/a113311
lift(Observable.Operator)80%n/a111111
amb(Observable, Observable, Observable, Observable, Observable)80%n/a111111
concat(Observable, Observable, Observable, Observable, Observable)80%n/a111111
concatDelayError(Observable, Observable, Observable, Observable, Observable)80%n/a111111
from(Future, Scheduler)80%n/a112211
mergeDelayError(Observable, Observable, Observable, Observable, Observable)80%n/a111111
timer(long, TimeUnit, Scheduler)80%n/a111111
zip(Observable[], FuncN)80%n/a111111
buffer(Func0)80%n/a111111
buffer(int, int)80%n/a111111
buffer(Observable, Func1)80%n/a111111
buffer(Observable, int)80%n/a111111
collect(Func0, Action2)80%n/a111111
delay(Func1)80%n/a111111
elementAtOrDefault(int, Object)80%n/a111111
exists(Func1)80%n/a111111
flatMap(Func1, Func1, Func0, int)80%n/a111111
groupBy(Func1, Func1)80%n/a111111
lastOrDefault(Object, Func1)80%n/a111111
onBackpressureBuffer(long, Action0)80%n/a111111
reduce(Object, Func2)80%n/a111111
replay(Func1, int, long, TimeUnit)80%n/a111111
replay(Func1, int, Scheduler)80%n/a112211
replay(Func1, long, TimeUnit, Scheduler)80%n/a112211
retry(Func2)80%n/a111111
scan(Object, Func2)80%n/a111111
skipWhile(Func1)80%n/a111111
startWith(Object, Object, Object, Object)80%n/a111111
takeLastBuffer(int, long, TimeUnit, Scheduler)80%n/a111111
toMap(Func1)80%n/a111111
toMap(Func1, Func1)80%n/a111111
toMultimap(Func1)80%n/a111111
toMultimap(Func1, Func1)80%n/a111111
toSortedList(Func2)80%n/a111111
toSortedList(Func2, int)80%n/a111111
withLatestFrom(Observable, Func2)80%n/a111111
window(long, long, TimeUnit)80%n/a111111
window(long, long, TimeUnit, Scheduler)80%n/a111111
window(long, TimeUnit, int, Scheduler)80%n/a111111
window(Observable, Func1)80%n/a111111
zipWith(Iterable, Func2)80%n/a111111
create(Action1, Emitter.BackpressureMode)70%n/a111111
amb(Observable, Observable, Observable, Observable)70%n/a111111
combineLatest(List, FuncN)70%n/a111111
combineLatest(Iterable, FuncN)70%n/a111111
concat(Observable, Observable, Observable, Observable)70%n/a111111
concatDelayError(Observable, Observable, Observable, Observable)70%n/a111111
mergeDelayError(Observable, Observable, Observable, Observable)70%n/a111111
all(Func1)70%n/a111111
buffer(long, long, TimeUnit)70%n/a111111
buffer(long, TimeUnit)70%n/a111111
buffer(long, TimeUnit, Scheduler)70%n/a111111
cast(Class)70%n/a111111
debounce(Func1)70%n/a111111
delaySubscription(Func0)70%n/a111111
distinct(Func1)70%n/a111111
distinctUntilChanged(Func1)70%n/a111111
distinctUntilChanged(Func2)70%n/a111111
doOnEach(Observer)70%n/a111111
doOnRequest(Action1)70%n/a111111
doOnSubscribe(Action0)70%n/a111111
doOnUnsubscribe(Action0)70%n/a111111
elementAt(int)70%n/a111111
filter(Func1)70%n/a111111
finallyDo(Action0)70%n/a111111
doAfterTerminate(Action0)70%n/a111111
flatMap(Func1, Func1, Func0)70%n/a111111
flatMapIterable(Func1, Func2, int)70%n/a111111
forEach(Action1, Action1, Action0)70%n/a112211
groupBy(Func1)70%n/a111111
last(Func1)70%n/a111111
map(Func1)70%n/a111111
ofType(Class)70%n/a111111
onBackpressureBuffer(long)70%n/a111111
onBackpressureDrop(Action1)70%n/a111111
onErrorResumeNext(Func1)70%n/a111111
reduce(Func2)70%n/a111111
replay(Func1, long, TimeUnit)70%n/a111111
replay(Func1, Scheduler)70%n/a113311
replay(int, long, TimeUnit)70%n/a111111
sample(Observable)70%n/a111111
scan(Func2)70%n/a111111
singleOrDefault(Object)70%n/a111111
skip(int)70%n/a111111
skipLast(int)70%n/a111111
skipUntil(Observable)70%n/a111111
startWith(Object, Object, Object)70%n/a111111
take(int)70%n/a111111
takeLast(int, long, TimeUnit)70%n/a111111
takeLastBuffer(int, long, TimeUnit)70%n/a111111
takeLastBuffer(long, TimeUnit, Scheduler)70%n/a111111
takeUntil(Observable)70%n/a111111
takeWhile(Func1)70%n/a111111
takeUntil(Func1)70%n/a111111
timeInterval(Scheduler)70%n/a111111
timeout(long, TimeUnit)70%n/a111111
timeout(long, TimeUnit, Observable)70%n/a111111
timeout(long, TimeUnit, Scheduler)70%n/a111111
timestamp(Scheduler)70%n/a111111
toSortedList()70%n/a111111
toSortedList(int)70%n/a111111
unsubscribeOn(Scheduler)70%n/a111111
window(Func0)70%n/a111111
window(long, TimeUnit)70%n/a111111
window(long, TimeUnit, int)70%n/a111111
window(long, TimeUnit, Scheduler)70%n/a111111
window(Observable)70%n/a111111
Observable(Observable.OnSubscribe)60%n/a113311
create(Observable.OnSubscribe)60%n/a111111
unsafeCreate(Observable.OnSubscribe)60%n/a111111
toSingle()60%n/a111111
amb(Observable, Observable, Observable)60%n/a111111
concat(Observable, Observable, Observable)60%n/a111111
concatDelayError(Observable, Observable, Observable)60%n/a111111
defer(Func0)60%n/a111111
error(Throwable)60%n/a111111
from(Future, long, TimeUnit)60%n/a111111
from(Iterable)60%n/a111111
fromCallable(Callable)60%n/a111111
interval(long, TimeUnit)60%n/a111111
interval(long, TimeUnit, Scheduler)60%n/a111111
interval(long, long, TimeUnit)60%n/a111111
mergeDelayError(Observable, int)60%n/a111111
mergeDelayError(Observable, Observable, Observable)60%n/a111111
range(int, int, Scheduler)60%n/a111111
timer(long, long, TimeUnit)60%n/a111111
timer(long, long, TimeUnit, Scheduler)60%n/a111111
using(Func0, Func1, Action1)60%n/a111111
count()60%n/a111111
countLong()60%n/a111111
debounce(long, TimeUnit)60%n/a111111
delay(long, TimeUnit)60%n/a111111
delaySubscription(long, TimeUnit)60%n/a111111
concatEager(Iterable, int)60%n/a111111
firstOrDefault(Object)60%n/a111111
firstOrDefault(Object, Func1)60%n/a111111
flatMapCompletable(Func1)60%n/a111111
flatMapCompletable(Func1, boolean)60%n/a111111
flatMapIterable(Func1, Func2)60%n/a111111
flatMapSingle(Func1)60%n/a111111
flatMapSingle(Func1, boolean)60%n/a111111
forEach(Action1, Action1)60%n/a112211
lastOrDefault(Object)60%n/a111111
observeOn(Scheduler, int)60%n/a111111
observeOn(Scheduler, boolean)60%n/a111111
onTerminateDetach()60%n/a111111
repeatWhen(Func1, Scheduler)60%n/a111111
replay(Func1, int)60%n/a111111
replay(int, Scheduler)60%n/a111111
replay(long, TimeUnit)60%n/a111111
replay(long, TimeUnit, Scheduler)60%n/a111111
retryWhen(Func1, Scheduler)60%n/a111111
sample(long, TimeUnit)60%n/a111111
singleOrDefault(Object, Func1)60%n/a111111
skip(long, TimeUnit)60%n/a111111
skipLast(long, TimeUnit)60%n/a111111
startWith(Object, Object)60%n/a111111
take(long, TimeUnit)60%n/a111111
takeFirst(Func1)60%n/a111111
takeLast(long, TimeUnit)60%n/a111111
takeLastBuffer(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(Func0, Func1)60%n/a111111
timeout(Func1)60%n/a111111
timeout(Func1, Observable)60%n/a111111
sorted(Func2)60%n/a111111
compose(Observable.Transformer)50%n/a111111
amb(Observable, Observable)50%n/a111111
concat(Observable, Observable)50%n/a111111
concatDelayError(Observable, Observable)50%n/a111111
merge(Iterable, int)50%n/a111111
merge(Observable[], int)50%n/a111111
mergeDelayError(Observable)50%n/a111111
mergeDelayError(Iterable, int)50%n/a111111
mergeDelayError(Observable, Observable)50%n/a111111
sequenceEqual(Observable, Observable)50%n/a111111
sequenceEqual(Observable, Observable, Func2)50%n/a111111
switchOnNext(Observable)50%n/a111111
switchOnNextDelayError(Observable)50%n/a111111
timer(long, TimeUnit)50%n/a111111
buffer(int)50%n/a111111
buffer(Observable)50%n/a111111
concatMapIterable(Func1)50%n/a111111
contains(Object)50%n/a111111
defaultIfEmpty(Object)50%n/a111111
concatEager(Iterable)50%n/a111111
concatEager(Observable, int)50%n/a111111
concatMapEager(Func1)50%n/a111111
first()50%n/a111111
first(Func1)50%n/a111111
flatMapIterable(Func1)50%n/a111111
flatMapIterable(Func1, int)50%n/a111111
forEach(Action1)50%n/a112211
last()50%n/a111111
observeOn(Scheduler)50%n/a111111
onErrorResumeNext(Observable)50%n/a111111
onErrorReturn(Func1)50%n/a111111
onExceptionResumeNext(Observable)50%n/a111111
repeat(long, Scheduler)50%n/a111111
repeatWhen(Func1)50%n/a111111
replay(Func1)50%n/a111111
replay(Scheduler)50%n/a111111
retryWhen(Func1)50%n/a111111
single(Func1)50%n/a111111
startWith(Iterable)50%n/a111111
startWith(Object)50%n/a111111
switchMap(Func1)50%n/a111111
switchMapDelayError(Func1)50%n/a111111
takeLastBuffer(int)50%n/a111111
throttleLast(long, TimeUnit)50%n/a111111
throttleWithTimeout(long, TimeUnit)50%n/a111111
sorted()50%n/a111111
window(int)50%n/a111111
zipWith(Observable, Func2)50%n/a111111
to(Func1)40%n/a111111
amb(Iterable)40%n/a111111
concat(Iterable)40%n/a111111
concat(Observable)40%n/a111111
concatDelayError(Observable)40%n/a111111
concatDelayError(Iterable)40%n/a111111
from(Future)40%n/a111111
merge(Iterable)40%n/a111111
merge(Observable[])40%n/a111111
mergeDelayError(Iterable)40%n/a111111
ambWith(Observable)40%n/a111111
asObservable()40%n/a111111
cache(int)40%n/a111111
cacheWithInitialCapacity(int)40%n/a111111
concatWith(Observable)40%n/a111111
dematerialize()40%n/a111111
distinct()40%n/a111111
distinctUntilChanged()40%n/a111111
concatEager(Observable)40%n/a111111
ignoreElements()40%n/a111111
isEmpty()40%n/a111111
limit(int)40%n/a111111
materialize()40%n/a111111
mergeWith(Observable)40%n/a111111
onBackpressureBuffer()40%n/a111111
onBackpressureDrop()40%n/a111111
onBackpressureLatest()40%n/a111111
publish(Func1)40%n/a111111
repeat(Scheduler)40%n/a111111
repeat(long)40%n/a111111
replay(int)40%n/a111111
retry(long)40%n/a111111
serialize()40%n/a111111
share()40%n/a111111
single()40%n/a111111
startWith(Observable)40%n/a111111
subscribe(Subscriber)40%n/a111111
timeInterval()40%n/a111111
timestamp()40%n/a111111
toList()40%n/a111111
create(SyncOnSubscribe)30%n/a111111
create(AsyncOnSubscribe)30%n/a111111
toCompletable()30%n/a111111
just(Object)30%n/a111111
nest()30%n/a111111
cache()30%n/a111111
publish()30%n/a111111
repeat()30%n/a111111
replay()30%n/a111111
retry()30%n/a111111
toBlocking()30%n/a111111
empty()20%n/a111111
never()20%n/a111111