Skip to content

Observable method summary

Dave Moten edited this page Jul 10, 2015 · 1 revision
Method Signature
all Ob all(Func1)
amb static Ob amb(Ob,Ob,Ob,Ob)
ambWith Ob ambWith(Ob)
asObservable Ob asOb()
buffer Ob buffer(long,TimeUnit,Scheduler)
cache Ob cache()
cast Ob cast(Class)
collect Ob collect(Func0,Action2)
combineLatest static Ob combineLatest(Ob,Ob,Ob,Ob,Ob,Func5)
compose Ob compose(Ob$Transformer)
concat static Ob concat(Ob,Ob,Ob,Ob,Ob,Ob,Ob,Ob,Ob)
concatMap Ob concatMap(Func1)
concatWith Ob concatWith(Ob)
contains Ob contains(Object)
count Ob count()
countLong Ob countLong()
create static Ob create(Ob$OnSubscribe)
debounce Ob debounce(long,TimeUnit,Scheduler)
defaultIfEmpty Ob defaultIfEmpty(Object)
defer static Ob defer(Func0)
delay Ob delay(Func0,Func1)
delaySubscription Ob delaySubscription(long,TimeUnit)
dematerialize Ob dematerialize()
distinct Ob distinct()
distinctUntilChanged Ob distinctUntilChanged()
doOnCompleted Ob doOnCompleted(Action0)
doOnEach Ob doOnEach(Action1)
doOnError Ob doOnError(Action1)
doOnNext Ob doOnNext(Action1)
doOnRequest Ob doOnRequest(Action1)
doOnSubscribe Ob doOnSubscribe(Action0)
doOnTerminate Ob doOnTerminate(Action0)
doOnUnsubscribe Ob doOnUnsubscribe(Action0)
elementAt Ob elementAt(int)
elementAtOrDefault Ob elementAtOrDefault(int,Object)
empty static Ob empty()
equals boolean equals(Object)
error static Ob error(Throwable)
exists Ob exists(Func1)
filter Ob filter(Func1)
finallyDo Ob finallyDo(Action0)
first Ob first(Func1)
firstOrDefault Ob firstOrDefault(Object)
flatMap Ob flatMap(Func1)
flatMapIterable Ob flatMapIterable(Func1)
forEach void forEach(Action1)
from static Ob from(Iterable)
groupBy Ob groupBy(Func1,Func1)
groupJoin Ob groupJoin(Ob,Func1,Func1,Func2)
ignoreElements Ob ignoreElements()
interval static Ob interval(long,TimeUnit)
isEmpty Ob isEmpty()
join Ob join(Ob,Func1,Func1,Func2)
just static Ob just(Object)
last Ob last(Func1)
lastOrDefault Ob lastOrDefault(Object)
lift Ob lift(Ob$Operator)
limit Ob limit(int)
map Ob map(Func1)
materialize Ob materialize()
merge static Ob merge(Ob,Ob,Ob,Ob)
mergeDelayError static Ob mergeDelayError(Ob,Ob,Ob,Ob,Ob,Ob)
mergeWith Ob mergeWith(Ob)
nest Ob nest()
never static Ob never()
observeOn Ob observeOn(Scheduler)
ofType Ob ofType(Class)
onBackpressureBlock Ob onBackpressureBlock(int)
onBackpressureBuffer Ob onBackpressureBuffer(long,Action0)
onBackpressureDrop Ob onBackpressureDrop(Action1)
onBackpressureLatest Ob onBackpressureLatest()
onErrorResumeNext Ob onErrorResumeNext(Ob)
onErrorReturn Ob onErrorReturn(Func1)
onExceptionResumeNext Ob onExceptionResumeNext(Ob)
publish ConnectableOb publish()
range static Ob range(int,int,Scheduler)
reduce Ob reduce(Object,Func2)
repeat Ob repeat()
repeatWhen Ob repeatWhen(Func1,Scheduler)
replay Ob replay(Func1,int,long,TimeUnit,Scheduler)
retry Ob retry(long)
retryWhen Ob retryWhen(Func1)
sample Ob sample(long,TimeUnit,Scheduler)
scan Ob scan(Object,Func2)
sequenceEqual static Ob sequenceEqual(Ob,Ob)
serialize Ob serialize()
share Ob share()
single Ob single(Func1)
singleOrDefault Ob singleOrDefault(Object,Func1)
skip Ob skip(long,TimeUnit,Scheduler)
skipLast Ob skipLast(int)
skipUntil Ob skipUntil(Ob)
skipWhile Ob skipWhile(Func1)
startWith Ob startWith(Object,Object,Object,Object)
subscribe Subscription subscribe()
subscribeOn Ob subscribeOn(Scheduler)
switchIfEmpty Ob switchIfEmpty(Ob)
switchMap Ob switchMap(Func1)
switchOnNext static Ob switchOnNext(Ob)
take Ob take(long,TimeUnit,Scheduler)
takeFirst Ob takeFirst(Func1)
takeLast Ob takeLast(int,long,TimeUnit,Scheduler)
takeLastBuffer Ob takeLastBuffer(int)
takeUntil Ob takeUntil(Func1)
takeWhile Ob takeWhile(Func1)
throttleFirst Ob throttleFirst(long,TimeUnit)
throttleLast Ob throttleLast(long,TimeUnit)
throttleWithTimeout Ob throttleWithTimeout(long,TimeUnit)
timeInterval Ob timeInterval()
timeout Ob timeout(long,TimeUnit,Scheduler)
timer static Ob timer(long,long,TimeUnit)
timestamp Ob timestamp(Scheduler)
toBlocking BlockingOb toBlocking()
toList Ob toList()
toMap Ob toMap(Func1,Func1)
toMultimap Ob toMultimap(Func1)
toSortedList Ob toSortedList(Func2)
toString String toString()
unsafeSubscribe Subscription unsafeSubscribe(Subscriber)
unsubscribeOn Ob unsubscribeOn(Scheduler)
using static Ob using(Func0,Func1,Action1,boolean)
wait void wait() throws InterruptedException
window Ob window(long,long,TimeUnit)
withLatestFrom Ob withLatestFrom(Ob,Func2)
zip static Ob zip(Ob,Ob,Ob,Ob,Ob,Func5)
zipWith Ob zipWith(Iterable,Func2)
Clone this wiki locally