froussios / intro-to-rxjava Goto Github PK
View Code? Open in Web Editor NEWAn extensive tutorial on RxJava
intro-to-rxjava's People
Contributors
Stargazers
Watchers
Forkers
ffgiraldez kevinvandervlist cadocruz stevecstian tiltman laygr uknownothingsnow sinsir yzp531 achmadns artemzi stevegury romanzhilich ashraf-revo vhoang55 effectda nextgenintelligence auxility taruvai huylv pranavlathigara vudunguit abenhmida ctranxuan anarefin gyzclw abhishekparwal nazarcybulskij utnas kevinmost jiayanguo hyshan maniacs-m pietsmit diegopacheco gorgija nathaniel100 mohammed90 goodev hejiero jtfernandes-sky franciscoe-hudl sujaybhowmick thanhniencung ptemplier great kherink kelebro63 fieldistor satish-trivium htoooth yuhangwang raymondhjm reactivedroid archie-lab albertchiu vinodkashyap grenderg yangmxi isdom rxsmart dencheek raviu vorsicht anhdenday glcoding cdhillon armcha junlapong orionthewake bangjin the-bytecode amanurat vmlinz alteadown chintootech gogobook rkand4 klgleb tonmoy71 believe3301 fifa0329 lengxf foto-andreas cuijfboy dharmakshetri brunocrodriguessouza anilkumargt mystdeim sergiogeek7 ciwhiz tsiry95 chuumong jgabrielfreitas bss-duy alex1989 coolmeen beyondervn mdnazmulhasan theanilpaudelintro-to-rxjava's Issues
Update for RxJava 2.0?
As one of the better intros to RxJava it'd be nice to know that it will stay relevant as RxJava evolves.
Now that RxJava 2.0 is out are there any plans to update this intro to reflect what was learned in the 1.X iteration and led to the 2.X rewrite?
Examples
Operators covered
-
Observable<java.lang.Boolean> all(Func1<? super T,java.lang.Boolean> predicate) -
static <T> Observable<T> amb(java.lang.Iterable<? extends Observable<? extends T>> sources) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8, Observable<? extends T> o9) -
Observable<T> ambWith(Observable<? extends T> t1) -
Observable<T> asObservable() -
<TClosing> Observable<java.util.List<T>> buffer(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector) -
Observable<java.util.List<T>> buffer(int count) -
Observable<java.util.List<T>> buffer(int count, int skip) -
Observable<java.util.List<T>> buffer(long timespan, long timeshift, java.util.concurrent.TimeUnit unit) -
Observable<java.util.List<T>> buffer(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit) -
Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count) -
Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler) -
Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<TOpening,TClosing> Observable<java.util.List<T>> buffer(Observable<? extends TOpening> bufferOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> bufferClosingSelector) -
<B> Observable<java.util.List<T>> buffer(Observable<B> boundary) -
<B> Observable<java.util.List<T>> buffer(Observable<B> boundary, int initialCapacity) -
Observable<T> cache() -
Observable<T> cache(int capacity) -
<R> Observable<R> cast(java.lang.Class<R> klass) -
<R> Observable<R> collect(Func0<R> stateFactory, Action2<R,? super T> collector) -
static <T,R> Observable<R> combineLatest(java.util.List<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction) -
static <T1,T2,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Func2<? super T1,? super T2,? extends R> combineFunction) -
static <T1,T2,T3,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1,? super T2,? super T3,? extends R> combineFunction) -
static <T1,T2,T3,T4,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Func4<? super T1,? super T2,? super T3,? super T4,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,T6,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,T6,T7,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,T6,T7,T8,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Observable<? extends T9> o9, Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction) -
<R> Observable<R> compose(Observable.Transformer<? super T,? extends R> transformer) -
static <T> Observable<T> concat(Observable<? extends Observable<? extends T>> observables) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9) -
<R> Observable<R> concatMap(Func1<? super T,? extends Observable<? extends R>> func) -
Observable<T> concatWith(Observable<? extends T> t1) -
Observable<java.lang.Boolean> contains(java.lang.Object element) -
Observable<java.lang.Integer> count() -
Observable<java.lang.Long> countLong() -
static <T> Observable<T> create(Observable.OnSubscribe<T> f) -
<U> Observable<T> debounce(Func1<? super T,? extends Observable<U>> debounceSelector) -
Observable<T> debounce(long timeout, java.util.concurrent.TimeUnit unit) -
Observable<T> debounce(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> defaultIfEmpty(T defaultValue) -
static <T> Observable<T> defer(Func0<Observable<T>> observableFactory) -
<U,V> Observable<T> delay(Func0<? extends Observable<U>> subscriptionDelay, Func1<? super T,? extends Observable<V>> itemDelay) -
<U> Observable<T> delay(Func1<? super T,? extends Observable<U>> itemDelay) -
Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit) -
Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<U> Observable<T> delaySubscription(Func0<? extends Observable<U>> subscriptionDelay) -
Observable<T> delaySubscription(long delay, java.util.concurrent.TimeUnit unit) -
Observable<T> delaySubscription(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<T2> Observable<T2> dematerialize() -
Observable<T> distinct() -
<U> Observable<T> distinct(Func1<? super T,? extends U> keySelector) -
Observable<T> distinctUntilChanged() -
<U> Observable<T> distinctUntilChanged(Func1<? super T,? extends U> keySelector) -
Observable<T> doOnCompleted(Action0 onCompleted) -
Observable<T> doOnEach(Action1<Notification<? super T>> onNotification) -
Observable<T> doOnEach(Observer<? super T> observer) -
Observable<T> doOnError(Action1<java.lang.Throwable> onError) -
Observable<T> doOnNext(Action1<? super T> onNext) -
Observable<T> doOnRequest(Action1<java.lang.Long> onRequest) -
Observable<T> doOnSubscribe(Action0 subscribe) -
Observable<T> doOnTerminate(Action0 onTerminate) -
Observable<T> doOnUnsubscribe(Action0 unsubscribe) -
Observable<T> elementAt(int index) -
Observable<T> elementAtOrDefault(int index, T defaultValue) -
static <T> Observable<T> empty() -
static <T> Observable<T> error(java.lang.Throwable exception) -
Observable<java.lang.Boolean> exists(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> filter(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> finallyDo(Action0 action) -
Observable<T> first() -
Observable<T> first(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> firstOrDefault(T defaultValue) -
Observable<T> firstOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate) -
<R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends R>> func) -
<R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends R>> onNext, Func1<? super java.lang.Throwable,? extends Observable<? extends R>> onError, Func0<? extends Observable<? extends R>> onCompleted) -
<U,R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector) -
<R> Observable<R> flatMapIterable(Func1<? super T,? extends java.lang.Iterable<? extends R>> collectionSelector) -
<U,R> Observable<R> flatMapIterable(Func1<? super T,? extends java.lang.Iterable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector) -
void forEach(Action1<? super T> onNext) -
void forEach(Action1<? super T> onNext, Action1<java.lang.Throwable> onError) -
void forEach(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete) -
static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future) -
static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future, long timeout, java.util.concurrent.TimeUnit unit) -
static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future, Scheduler scheduler) -
static <T> Observable<T> from(java.lang.Iterable<? extends T> iterable) -
static <T> Observable<T> from(T[] array) -
<K> Observable<GroupedObservable<K,T>> groupBy(Func1<? super T,? extends K> keySelector) -
<K,R> Observable<GroupedObservable<K,R>> groupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> elementSelector) -
<T2,D1,D2,R> Observable<R> groupJoin(Observable<T2> right, Func1<? super T,? extends Observable<D1>> leftDuration, Func1<? super T2,? extends Observable<D2>> rightDuration, Func2<? super T,? super Observable<T2>,? extends R> resultSelector) -
Observable<T> ignoreElements() -
static Observable<java.lang.Long> interval(long interval, java.util.concurrent.TimeUnit unit) -
static Observable<java.lang.Long> interval(long interval, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<java.lang.Boolean> isEmpty() -
<TRight,TLeftDuration,TRightDuration,R> Observable<R> join(Observable<TRight> right, Func1<T,Observable<TLeftDuration>> leftDurationSelector, Func1<TRight,Observable<TRightDuration>> rightDurationSelector, Func2<T,TRight,R> resultSelector) -
static <T> Observable<T> just(T value) -
static <T> Observable<T> just(T t1, T t2) -
static <T> Observable<T> just(T t1, T t2, T t3) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10) -
Observable<T> last() -
Observable<T> last(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> lastOrDefault(T defaultValue) -
Observable<T> lastOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate) -
<R> Observable<R> lift(Observable.Operator<? extends R,? super T> lift) -
Observable<T> limit(int num) -
<R> Observable<R> map(Func1<? super T,? extends R> func) -
Observable<Notification<T>> materialize() -
static <T> Observable<T> merge(java.lang.Iterable<? extends Observable<? extends T>> sequences) -
static <T> Observable<T> merge(java.lang.Iterable<? extends Observable<? extends T>> sequences, int maxConcurrent) -
static <T> Observable<T> merge(Observable<? extends Observable<? extends T>> source) -
static <T> Observable<T> merge(Observable<? extends Observable<? extends T>> source, int maxConcurrent) -
static <T> Observable<T> merge(Observable<? extends T>[] sequences) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2,Observable<? extends T> t3)` -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9) -
static <T> Observable<T> mergeDelayError(Observable<? extends Observable<? extends T>> source) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9) -
Observable<T> mergeWith(Observable<? extends T> t1) -
Observable<Observable<T>> nest() -
static <T> Observable<T> never() -
Observable<T> observeOn(Scheduler scheduler) -
<R> Observable<R> ofType(java.lang.Class<R> klass) -
Observable<T> onBackpressureBuffer() -
Observable<T> onBackpressureBuffer(long capacity) -
Observable<T> onBackpressureDrop() -
Observable<T> onErrorResumeNext(Func1<java.lang.Throwable,? extends Observable<? extends T>> resumeFunction) -
Observable<T> onErrorResumeNext(Observable<? extends T> resumeSequence) -
Observable<T> onErrorReturn(Func1<java.lang.Throwable,? extends T> resumeFunction) -
Observable<T> onExceptionResumeNext(Observable<? extends T> resumeSequence) -
ConnectableObservable<T> publish() -
<R> Observable<R> publish(Func1<? super Observable<T>,? extends Observable<R>> selector) -
static Observable<java.lang.Integer> range(int start, int count) -
static Observable<java.lang.Integer> range(int start, int count, Scheduler scheduler) -
Observable<T> reduce(Func2<T,T,T> accumulator) -
<R> Observable<R> reduce(R initialValue, Func2<R,? super T,R> accumulator) -
Observable<T> repeat() -
Observable<T> repeat(long count) -
Observable<T> repeat(long count, Scheduler scheduler) -
Observable<T> repeat(Scheduler scheduler) -
Observable<T> repeatWhen(Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler) -
Observable<T> repeatWhen(Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler, Scheduler scheduler) -
ConnectableObservable<T> replay() -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, Scheduler scheduler) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, java.util.concurrent.TimeUnit unit) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, Scheduler scheduler) -
ConnectableObservable<T> replay(int bufferSize) -
ConnectableObservable<T> replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit) -
ConnectableObservable<T> replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
ConnectableObservable<T> replay(int bufferSize, Scheduler scheduler) -
ConnectableObservable<T> replay(long time, java.util.concurrent.TimeUnit unit) -
ConnectableObservable<T> replay(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
ConnectableObservable<T> replay(Scheduler scheduler) -
Observable<T> retry() -
Observable<T> retry(Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate) -
Observable<T> retry(long count) -
Observable<T> retryWhen(Func1<? super Observable<? extends java.lang.Throwable>,? extends Observable<?>> notificationHandler) -
Observable<T> retryWhen(Func1<? super Observable<? extends java.lang.Throwable>,? extends Observable<?>> notificationHandler, Scheduler scheduler) -
Observable<T> sample(long period, java.util.concurrent.TimeUnit unit) -
Observable<T> sample(long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<U> Observable<T> sample(Observable<U> sampler) -
Observable<T> scan(Func2<T,T,T> accumulator) -
<R> Observable<R> scan(R initialValue, Func2<R,? super T,R> accumulator) -
static <T> Observable<java.lang.Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second) -
static <T> Observable<java.lang.Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T,? super T,java.lang.Boolean> equality) -
Observable<T> serialize() -
Observable<T> share() -
Observable<T> single() -
Observable<T> single(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> singleOrDefault(T defaultValue) -
Observable<T> singleOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> skip(int num) -
Observable<T> skip(long time, java.util.concurrent.TimeUnit unit) -
Observable<T> skip(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> skipLast(int count) -
Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit) -
Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<U> Observable<T> skipUntil(Observable<U> other) -
Observable<T> skipWhile(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> startWith(java.lang.Iterable<T> values) -
Observable<T> startWith(Observable<T> values) -
Observable<T> startWith(T t1) -
Observable<T> startWith(T t1, T t2) -
Observable<T> startWith(T t1, T t2, T t3) -
Observable<T> startWith(T t1, T t2, T t3, T t4) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) -
Subscription subscribe() -
Subscription subscribe(Action1<? super T> onNext) -
Subscription subscribe(Action1<? super T> onNext, Action1<java.lang.Throwable> onError) -
Subscription subscribe(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete) -
Subscription subscribe(Observer<? super T> observer) -
Subscription subscribe(Subscriber<? super T> subscriber) -
Observable<T> subscribeOn(Scheduler scheduler) -
<R> Observable<R> switchMap(Func1<? super T,? extends Observable<? extends R>> func) -
static <T> Observable<T> switchOnNext(Observable<? extends Observable<? extends T>> sequenceOfSequences) -
Observable<T> take(int num) -
Observable<T> take(long time, java.util.concurrent.TimeUnit unit) -
Observable<T> take(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> takeFirst(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> takeLast(int count) -
Observable<T> takeLast(int count, long time, java.util.concurrent.TimeUnit unit) -
Observable<T> takeLast(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit) -
Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<java.util.List<T>> takeLastBuffer(int count) -
Observable<java.util.List<T>> takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit) -
Observable<java.util.List<T>> takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<java.util.List<T>> takeLastBuffer(long time, java.util.concurrent.TimeUnit unit) -
Observable<java.util.List<T>> takeLastBuffer(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> takeUntil(Func1<? super T,java.lang.Boolean> stopPredicate) -
<E> Observable<T> takeUntil(Observable<? extends E> other) -
Observable<T> takeWhile(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> throttleFirst(long windowDuration, java.util.concurrent.TimeUnit unit) -
Observable<T> throttleFirst(long skipDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit) -
Observable<T> throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit) -
Observable<T> throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<TimeInterval<T>> timeInterval() -
Observable<TimeInterval<T>> timeInterval(Scheduler scheduler) -
<U,V> Observable<T> timeout(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector) -
<U,V> Observable<T> timeout(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other) -
<V> Observable<T> timeout(Func1<? super T,? extends Observable<V>> timeoutSelector) -
<V> Observable<T> timeout(Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other) -
Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit) -
Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable<? extends T> other) -
Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler) -
Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Scheduler scheduler) -
static Observable<java.lang.Long> timer(long initialDelay, long period, java.util.concurrent.TimeUnit unit) -
static Observable<java.lang.Long> timer(long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
static Observable<java.lang.Long> timer(long delay, java.util.concurrent.TimeUnit unit) -
static Observable<java.lang.Long> timer(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<Timestamped<T>> timestamp() -
Observable<Timestamped<T>> timestamp(Scheduler scheduler) -
BlockingObservable<T> toBlocking() -
Observable<java.util.List<T>> toList() -
<K> Observable<java.util.Map<K,T>> toMap(Func1<? super T,? extends K> keySelector) -
<K,V> Observable<java.util.Map<K,V>> toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) -
<K,V> Observable<java.util.Map<K,V>> toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,V>> mapFactory) -
<K> Observable<java.util.Map<K,java.util.Collection<T>>> toMultimap(Func1<? super T,? extends K> keySelector) -
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) -
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,java.util.Collection<V>>> mapFactory) -
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,java.util.Collection<V>>> mapFactory, Func1<? super K,? extends java.util.Collection<V>> collectionFactory) -
Observable<java.util.List<T>> toSortedList() -
Observable<java.util.List<T>> toSortedList(Func2<? super T,? super T,java.lang.Integer> sortFunction) -
Subscription unsafeSubscribe(Subscriber<? super T> subscriber) -
Observable<T> unsubscribeOn(Scheduler scheduler) -
static <T,Resource> Observable<T> using(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> disposeAction) -
<TClosing> Observable<Observable<T>> window(Func0<? extends Observable<? extends TClosing>> closingSelector) -
Observable<Observable<T>> window(int count) -
Observable<Observable<T>> window(int count, int skip) -
Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit) -
Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler) -
Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit) -
Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, int count) -
Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler) -
Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<TOpening,TClosing> Observable<Observable<T>> window(Observable<? extends TOpening> windowOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> closingSelector) -
<U> Observable<Observable<T>> window(Observable<U> boundary) -
static <R> Observable<R> zip(java.lang.Iterable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction) -
static <R> Observable<R> zip(Observable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction) -
static <T1,T2,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Func2<? super T1,? super T2,? extends R> zipFunction) -
static <T1,T2,T3,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1,? super T2,? super T3,? extends R> zipFunction) -
static <T1,T2,T3,T4,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Func4<? super T1,? super T2,? super T3,? super T4,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,T6,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,T6,T7,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,T6,T7,T8,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Observable<? extends T9> o9, Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction) -
<T2,R> Observable<R> zipWith(java.lang.Iterable<? extends T2> other, Func2<? super T,? super T2,? extends R> zipFunction) - `<T2,R> Observable zipWith(Observable<? extends T2> other, Func2<? super T,? super T2,? extends R> zipFunction)``
Other language
Other language interpreter?
Make this into a GitBook
Just a suggestion, but you may want to consider making this into a GitBook. It's just more pleasant for reading.
Subject.asObservable() should be changed to Subject.hide()
In Part 3 in the Encapsulating With asObservable section you use asObservable() which is no longer used.
See What's different in 2.0 specifically in the Instance methods section where it says that
asObservable renamed to hide(), hides all identities now
Link from book to examples
Hot and Cold observables - Disconnecting: Example output is not correct.
Hi,
Please check the code example here:
ConnectableObservable<Long> connectable = Observable.interval(200, TimeUnit.MILLISECONDS).publish();
Subscription s = connectable.connect();
connectable.subscribe(i -> System.out.println(i));
Thread.sleep(1000);
System.out.println("Closing connection");
s.unsubscribe();
Thread.sleep(1000);
System.out.println("Reconnecting");
s = connectable.connect();The actual output is:
0
1
2
3
4
Closing connection
Reconnecting
Notice no more values appear after Reconnecting. Looks like calling unsubscribe on the ConnectableObservable's subscription also terminates subsequent subscriptions, too. I need to call connectable.subscribe(i -> System.out.println(i)) again in order to produce output while the text says that 'old observers will begin receiving values again' after calling connect() on the ConnectableObservable object. I'm using RxJava 1.0.14.
Problems with the basics
Example with 'sequenceEqual' operator is wrong
Hi,
going through your excellent tutorial I I've already noticed that I cannot write a function like this:
Observable.sequenceEqual(strings, ints, (s,i) -> s.equals(i.toString()))
//Observable.sequenceEqual(strings, ints)
.subscribe(
v -> System.out.println(v),
e -> System.out.println("Error: " + e),
() -> System.out.println("Completed")
);
The working version should be like this:
Subscription sequenceEqual = Observable.sequenceEqual(
just1, just2, (s, i) -> s.equals(just1.toString())).subscribe();
where declarations of just1 and `just2' variables:
Observable<Integer> just1 = Observable.just(1, 2, 3);
Observable<String> just2 = Observable.just("1", "2", "3");
Did you forgot to declare a variable or it changed with newer version of RxJava?
I'm using this dependencies:
compile 'io.reactivex:rxjava:1.1.1'
compile 'io.reactivex:rxandroid:1.1.0'
Cheers
Observable.just() is a hot observable and not cold observable as mentioned in the doc.
`fun main() {
Observable.just(returnInt())
}
fun returnInt() : Int {
println("inside return block")
return 2;
}`
Even without subscribing to the Observable.just(), it prints the statement, which means it is a hot observable and not a cold observable.
Possible improvements
- move
skipLastandtakeLastto a later subchapter: too early for discussing windows - move
concatMaptoconcatsubchapter
Operator coverage
Operators covered
-
Observable<java.lang.Boolean> all(Func1<? super T,java.lang.Boolean> predicate) -
static <T> Observable<T> amb(java.lang.Iterable<? extends Observable<? extends T>> sources) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8) -
static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8, Observable<? extends T> o9) -
Observable<T> ambWith(Observable<? extends T> t1) -
Observable<T> asObservable() -
<TClosing> Observable<java.util.List<T>> buffer(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector) -
Observable<java.util.List<T>> buffer(int count) -
Observable<java.util.List<T>> buffer(int count, int skip) -
Observable<java.util.List<T>> buffer(long timespan, long timeshift, java.util.concurrent.TimeUnit unit) -
Observable<java.util.List<T>> buffer(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit) -
Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count) -
Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler) -
Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<TOpening,TClosing> Observable<java.util.List<T>> buffer(Observable<? extends TOpening> bufferOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> bufferClosingSelector) -
<B> Observable<java.util.List<T>> buffer(Observable<B> boundary) -
<B> Observable<java.util.List<T>> buffer(Observable<B> boundary, int initialCapacity) -
Observable<T> cache() -
Observable<T> cache(int capacity) -
<R> Observable<R> cast(java.lang.Class<R> klass) -
<R> Observable<R> collect(Func0<R> stateFactory, Action2<R,? super T> collector) -
static <T,R> Observable<R> combineLatest(java.util.List<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction) -
static <T1,T2,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Func2<? super T1,? super T2,? extends R> combineFunction) -
static <T1,T2,T3,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1,? super T2,? super T3,? extends R> combineFunction) -
static <T1,T2,T3,T4,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Func4<? super T1,? super T2,? super T3,? super T4,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,T6,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,T6,T7,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,T6,T7,T8,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction) -
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Observable<? extends T9> o9, Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction) -
<R> Observable<R> compose(Observable.Transformer<? super T,? extends R> transformer) -
static <T> Observable<T> concat(Observable<? extends Observable<? extends T>> observables) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8) -
static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9) -
<R> Observable<R> concatMap(Func1<? super T,? extends Observable<? extends R>> func) -
Observable<T> concatWith(Observable<? extends T> t1) -
Observable<java.lang.Boolean> contains(java.lang.Object element) -
Observable<java.lang.Integer> count() -
Observable<java.lang.Long> countLong() -
static <T> Observable<T> create(Observable.OnSubscribe<T> f) -
<U> Observable<T> debounce(Func1<? super T,? extends Observable<U>> debounceSelector) -
Observable<T> debounce(long timeout, java.util.concurrent.TimeUnit unit) -
Observable<T> debounce(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> defaultIfEmpty(T defaultValue) -
static <T> Observable<T> defer(Func0<Observable<T>> observableFactory) -
<U,V> Observable<T> delay(Func0<? extends Observable<U>> subscriptionDelay, Func1<? super T,? extends Observable<V>> itemDelay) -
<U> Observable<T> delay(Func1<? super T,? extends Observable<U>> itemDelay) -
Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit) -
Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<U> Observable<T> delaySubscription(Func0<? extends Observable<U>> subscriptionDelay) -
Observable<T> delaySubscription(long delay, java.util.concurrent.TimeUnit unit) -
Observable<T> delaySubscription(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<T2> Observable<T2> dematerialize() -
Observable<T> distinct() -
<U> Observable<T> distinct(Func1<? super T,? extends U> keySelector) -
Observable<T> distinctUntilChanged() -
<U> Observable<T> distinctUntilChanged(Func1<? super T,? extends U> keySelector) -
Observable<T> doOnCompleted(Action0 onCompleted) -
Observable<T> doOnEach(Action1<Notification<? super T>> onNotification) -
Observable<T> doOnEach(Observer<? super T> observer) -
Observable<T> doOnError(Action1<java.lang.Throwable> onError) -
Observable<T> doOnNext(Action1<? super T> onNext) -
Observable<T> doOnRequest(Action1<java.lang.Long> onRequest) -
Observable<T> doOnSubscribe(Action0 subscribe) -
Observable<T> doOnTerminate(Action0 onTerminate) -
Observable<T> doOnUnsubscribe(Action0 unsubscribe) -
Observable<T> elementAt(int index) -
Observable<T> elementAtOrDefault(int index, T defaultValue) -
static <T> Observable<T> empty() -
static <T> Observable<T> error(java.lang.Throwable exception) -
Observable<java.lang.Boolean> exists(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> filter(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> finallyDo(Action0 action) -
Observable<T> first() -
Observable<T> first(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> firstOrDefault(T defaultValue) -
Observable<T> firstOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate) -
<R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends R>> func) -
<R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends R>> onNext, Func1<? super java.lang.Throwable,? extends Observable<? extends R>> onError, Func0<? extends Observable<? extends R>> onCompleted) -
<U,R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector) -
<R> Observable<R> flatMapIterable(Func1<? super T,? extends java.lang.Iterable<? extends R>> collectionSelector) -
<U,R> Observable<R> flatMapIterable(Func1<? super T,? extends java.lang.Iterable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector) -
void forEach(Action1<? super T> onNext) -
void forEach(Action1<? super T> onNext, Action1<java.lang.Throwable> onError) -
void forEach(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete) -
static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future) -
static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future, long timeout, java.util.concurrent.TimeUnit unit) -
static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future, Scheduler scheduler) -
static <T> Observable<T> from(java.lang.Iterable<? extends T> iterable) -
static <T> Observable<T> from(T[] array) -
<K> Observable<GroupedObservable<K,T>> groupBy(Func1<? super T,? extends K> keySelector) -
<K,R> Observable<GroupedObservable<K,R>> groupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> elementSelector) -
<T2,D1,D2,R> Observable<R> groupJoin(Observable<T2> right, Func1<? super T,? extends Observable<D1>> leftDuration, Func1<? super T2,? extends Observable<D2>> rightDuration, Func2<? super T,? super Observable<T2>,? extends R> resultSelector) -
Observable<T> ignoreElements() -
static Observable<java.lang.Long> interval(long interval, java.util.concurrent.TimeUnit unit) -
static Observable<java.lang.Long> interval(long interval, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<java.lang.Boolean> isEmpty() -
<TRight,TLeftDuration,TRightDuration,R> Observable<R> join(Observable<TRight> right, Func1<T,Observable<TLeftDuration>> leftDurationSelector, Func1<TRight,Observable<TRightDuration>> rightDurationSelector, Func2<T,TRight,R> resultSelector) -
static <T> Observable<T> just(T value) -
static <T> Observable<T> just(T t1, T t2) -
static <T> Observable<T> just(T t1, T t2, T t3) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) -
static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10) -
Observable<T> last() -
Observable<T> last(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> lastOrDefault(T defaultValue) -
Observable<T> lastOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate) -
<R> Observable<R> lift(Observable.Operator<? extends R,? super T> lift) -
Observable<T> limit(int num) -
<R> Observable<R> map(Func1<? super T,? extends R> func) -
Observable<Notification<T>> materialize() -
static <T> Observable<T> merge(java.lang.Iterable<? extends Observable<? extends T>> sequences) -
static <T> Observable<T> merge(java.lang.Iterable<? extends Observable<? extends T>> sequences, int maxConcurrent) -
static <T> Observable<T> merge(Observable<? extends Observable<? extends T>> source) -
static <T> Observable<T> merge(Observable<? extends Observable<? extends T>> source, int maxConcurrent) -
static <T> Observable<T> merge(Observable<? extends T>[] sequences) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2,Observable<? extends T> t3)` -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8) -
static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9) -
static <T> Observable<T> mergeDelayError(Observable<? extends Observable<? extends T>> source) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8) -
static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9) -
Observable<T> mergeWith(Observable<? extends T> t1) -
Observable<Observable<T>> nest() -
static <T> Observable<T> never() -
Observable<T> observeOn(Scheduler scheduler) -
<R> Observable<R> ofType(java.lang.Class<R> klass) -
Observable<T> onBackpressureBuffer() -
Observable<T> onBackpressureBuffer(long capacity) -
Observable<T> onBackpressureDrop() -
Observable<T> onErrorResumeNext(Func1<java.lang.Throwable,? extends Observable<? extends T>> resumeFunction) -
Observable<T> onErrorResumeNext(Observable<? extends T> resumeSequence) -
Observable<T> onErrorReturn(Func1<java.lang.Throwable,? extends T> resumeFunction) -
Observable<T> onExceptionResumeNext(Observable<? extends T> resumeSequence) -
ConnectableObservable<T> publish() -
<R> Observable<R> publish(Func1<? super Observable<T>,? extends Observable<R>> selector) -
static Observable<java.lang.Integer> range(int start, int count) -
static Observable<java.lang.Integer> range(int start, int count, Scheduler scheduler) -
Observable<T> reduce(Func2<T,T,T> accumulator) -
<R> Observable<R> reduce(R initialValue, Func2<R,? super T,R> accumulator) -
Observable<T> repeat() -
Observable<T> repeat(long count) -
Observable<T> repeat(long count, Scheduler scheduler) -
Observable<T> repeat(Scheduler scheduler) -
Observable<T> repeatWhen(Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler) -
Observable<T> repeatWhen(Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler, Scheduler scheduler) -
ConnectableObservable<T> replay() -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, Scheduler scheduler) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, java.util.concurrent.TimeUnit unit) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, Scheduler scheduler) -
ConnectableObservable<T> replay(int bufferSize) -
ConnectableObservable<T> replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit) -
ConnectableObservable<T> replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
ConnectableObservable<T> replay(int bufferSize, Scheduler scheduler) -
ConnectableObservable<T> replay(long time, java.util.concurrent.TimeUnit unit) -
ConnectableObservable<T> replay(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
ConnectableObservable<T> replay(Scheduler scheduler) -
Observable<T> retry() -
Observable<T> retry(Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate) -
Observable<T> retry(long count) -
Observable<T> retryWhen(Func1<? super Observable<? extends java.lang.Throwable>,? extends Observable<?>> notificationHandler) -
Observable<T> retryWhen(Func1<? super Observable<? extends java.lang.Throwable>,? extends Observable<?>> notificationHandler, Scheduler scheduler) -
Observable<T> sample(long period, java.util.concurrent.TimeUnit unit) -
Observable<T> sample(long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<U> Observable<T> sample(Observable<U> sampler) -
Observable<T> scan(Func2<T,T,T> accumulator) -
<R> Observable<R> scan(R initialValue, Func2<R,? super T,R> accumulator) -
static <T> Observable<java.lang.Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second) -
static <T> Observable<java.lang.Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T,? super T,java.lang.Boolean> equality) -
Observable<T> serialize() -
Observable<T> share() -
Observable<T> single() -
Observable<T> single(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> singleOrDefault(T defaultValue) -
Observable<T> singleOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> skip(int num) -
Observable<T> skip(long time, java.util.concurrent.TimeUnit unit) -
Observable<T> skip(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> skipLast(int count) -
Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit) -
Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<U> Observable<T> skipUntil(Observable<U> other) -
Observable<T> skipWhile(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> startWith(java.lang.Iterable<T> values) -
Observable<T> startWith(Observable<T> values) -
Observable<T> startWith(T t1) -
Observable<T> startWith(T t1, T t2) -
Observable<T> startWith(T t1, T t2, T t3) -
Observable<T> startWith(T t1, T t2, T t3, T t4) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8) -
Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) -
Subscription subscribe() -
Subscription subscribe(Action1<? super T> onNext) -
Subscription subscribe(Action1<? super T> onNext, Action1<java.lang.Throwable> onError) -
Subscription subscribe(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete) -
Subscription subscribe(Observer<? super T> observer) -
Subscription subscribe(Subscriber<? super T> subscriber) -
Observable<T> subscribeOn(Scheduler scheduler) -
<R> Observable<R> switchMap(Func1<? super T,? extends Observable<? extends R>> func) -
static <T> Observable<T> switchOnNext(Observable<? extends Observable<? extends T>> sequenceOfSequences) -
Observable<T> take(int num) -
Observable<T> take(long time, java.util.concurrent.TimeUnit unit) -
Observable<T> take(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> takeFirst(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> takeLast(int count) -
Observable<T> takeLast(int count, long time, java.util.concurrent.TimeUnit unit) -
Observable<T> takeLast(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit) -
Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<java.util.List<T>> takeLastBuffer(int count) -
Observable<java.util.List<T>> takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit) -
Observable<java.util.List<T>> takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<java.util.List<T>> takeLastBuffer(long time, java.util.concurrent.TimeUnit unit) -
Observable<java.util.List<T>> takeLastBuffer(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> takeUntil(Func1<? super T,java.lang.Boolean> stopPredicate) -
<E> Observable<T> takeUntil(Observable<? extends E> other) -
Observable<T> takeWhile(Func1<? super T,java.lang.Boolean> predicate) -
Observable<T> throttleFirst(long windowDuration, java.util.concurrent.TimeUnit unit) -
Observable<T> throttleFirst(long skipDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit) -
Observable<T> throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<T> throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit) -
Observable<T> throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<TimeInterval<T>> timeInterval() -
Observable<TimeInterval<T>> timeInterval(Scheduler scheduler) -
<U,V> Observable<T> timeout(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector) -
<U,V> Observable<T> timeout(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other) -
<V> Observable<T> timeout(Func1<? super T,? extends Observable<V>> timeoutSelector) -
<V> Observable<T> timeout(Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other) -
Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit) -
Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable<? extends T> other) -
Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler) -
Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Scheduler scheduler) -
static Observable<java.lang.Long> timer(long initialDelay, long period, java.util.concurrent.TimeUnit unit) -
static Observable<java.lang.Long> timer(long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
static Observable<java.lang.Long> timer(long delay, java.util.concurrent.TimeUnit unit) -
static Observable<java.lang.Long> timer(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<Timestamped<T>> timestamp() -
Observable<Timestamped<T>> timestamp(Scheduler scheduler) -
BlockingObservable<T> toBlocking() -
Observable<java.util.List<T>> toList() -
<K> Observable<java.util.Map<K,T>> toMap(Func1<? super T,? extends K> keySelector) -
<K,V> Observable<java.util.Map<K,V>> toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) -
<K,V> Observable<java.util.Map<K,V>> toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,V>> mapFactory) -
<K> Observable<java.util.Map<K,java.util.Collection<T>>> toMultimap(Func1<? super T,? extends K> keySelector) -
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) -
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,java.util.Collection<V>>> mapFactory) -
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,java.util.Collection<V>>> mapFactory, Func1<? super K,? extends java.util.Collection<V>> collectionFactory) -
Observable<java.util.List<T>> toSortedList() -
Observable<java.util.List<T>> toSortedList(Func2<? super T,? super T,java.lang.Integer> sortFunction) -
Subscription unsafeSubscribe(Subscriber<? super T> subscriber) -
Observable<T> unsubscribeOn(Scheduler scheduler) -
static <T,Resource> Observable<T> using(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> disposeAction) -
<TClosing> Observable<Observable<T>> window(Func0<? extends Observable<? extends TClosing>> closingSelector) -
Observable<Observable<T>> window(int count) -
Observable<Observable<T>> window(int count, int skip) -
Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit) -
Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler) -
Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit) -
Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, int count) -
Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler) -
Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler) -
<TOpening,TClosing> Observable<Observable<T>> window(Observable<? extends TOpening> windowOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> closingSelector) -
<U> Observable<Observable<T>> window(Observable<U> boundary) -
static <R> Observable<R> zip(java.lang.Iterable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction) -
static <R> Observable<R> zip(Observable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction) -
static <T1,T2,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Func2<? super T1,? super T2,? extends R> zipFunction) -
static <T1,T2,T3,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1,? super T2,? super T3,? extends R> zipFunction) -
static <T1,T2,T3,T4,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Func4<? super T1,? super T2,? super T3,? super T4,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,T6,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,T6,T7,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,T6,T7,T8,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction) -
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Observable<? extends T9> o9, Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction) -
<T2,R> Observable<R> zipWith(java.lang.Iterable<? extends T2> other, Func2<? super T,? super T2,? extends R> zipFunction) - `<T2,R> Observable zipWith(Observable<? extends T2> other, Func2<? super T,? super T2,? extends R> zipFunction)``
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.