Froussios
commented
9 years ago Experimental operators
Observable<T> onBackpressureBlock()Observable<T> onBackpressureBlock(int maxQueueLength)Observable<T> onBackpressureBuffer(long capacity, Action0 onOverflow)Observable<T> switchIfEmpty(Observable<? extends T> alternate)
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)