-
Notifications
You must be signed in to change notification settings - Fork 29
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) |