Operator coverage #2
Comments
Froussios
added a commit
that referenced
this issue
Apr 25, 2015
#2 Covered `compose`, `lift` and `serialize`
|
Experimental operators
|
logrusx
pushed a commit
to logrusx/Intro-To-RxJava
that referenced
this issue
Sep 30, 2024
Fixed result output
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
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)The text was updated successfully, but these errors were encountered: