Title: Operator coverage · Issue #2 · Froussios/Intro-To-RxJava · GitHub
Open Graph Title: Operator coverage · Issue #2 · Froussios/Intro-To-RxJava
X Title: Operator coverage · Issue #2 · Froussios/Intro-To-RxJava
Description: Operators covered Observable
Open Graph Description: Operators covered Observable
X Description: Operators covered Observable<java.lang.Boolean> all(Func1<? super T,java.lang.Boolean> predicate) static <T> Observable<T> amb(java.lang.Iterable<? extends Observable<...
Opengraph URL: https://github.com/Froussios/Intro-To-RxJava/issues/2
X: @github
Domain: github.com
{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Operator coverage","articleBody":"### Operators covered\n- [x] `Observable\u003cjava.lang.Boolean\u003e all(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(java.lang.Iterable\u003c? extends Observable\u003c? extends T\u003e\u003e sources)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(Observable\u003c? extends T\u003e o1, Observable\u003c? extends T\u003e o2)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(Observable\u003c? extends T\u003e o1, Observable\u003c? extends T\u003e o2, Observable\u003c? extends T\u003e o3)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(Observable\u003c? extends T\u003e o1, Observable\u003c? extends T\u003e o2, Observable\u003c? extends T\u003e o3, Observable\u003c? extends T\u003e o4)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(Observable\u003c? extends T\u003e o1, Observable\u003c? extends T\u003e o2, Observable\u003c? extends T\u003e o3, Observable\u003c? extends T\u003e o4, Observable\u003c? extends T\u003e o5)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(Observable\u003c? extends T\u003e o1, Observable\u003c? extends T\u003e o2, Observable\u003c? extends T\u003e o3, Observable\u003c? extends T\u003e o4, Observable\u003c? extends T\u003e o5, Observable\u003c? extends T\u003e o6)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(Observable\u003c? extends T\u003e o1, Observable\u003c? extends T\u003e o2, Observable\u003c? extends T\u003e o3, Observable\u003c? extends T\u003e o4, Observable\u003c? extends T\u003e o5, Observable\u003c? extends T\u003e o6, Observable\u003c? extends T\u003e o7)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(Observable\u003c? extends T\u003e o1, Observable\u003c? extends T\u003e o2, Observable\u003c? extends T\u003e o3, Observable\u003c? extends T\u003e o4, Observable\u003c? extends T\u003e o5, Observable\u003c? extends T\u003e o6, Observable\u003c? extends T\u003e o7, Observable\u003c? extends T\u003e o8)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e amb(Observable\u003c? extends T\u003e o1, Observable\u003c? extends T\u003e o2, Observable\u003c? extends T\u003e o3, Observable\u003c? extends T\u003e o4, Observable\u003c? extends T\u003e o5, Observable\u003c? extends T\u003e o6, Observable\u003c? extends T\u003e o7, Observable\u003c? extends T\u003e o8, Observable\u003c? extends T\u003e o9)`\n- [x] `Observable\u003cT\u003e ambWith(Observable\u003c? extends T\u003e t1)`\n- [x] `Observable\u003cT\u003e asObservable()`\n- [x] `\u003cTClosing\u003e Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(Func0\u003c? extends Observable\u003c? extends TClosing\u003e\u003e bufferClosingSelector)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(int count)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(int count, int skip)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(long timespan, long timeshift, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(long timespan, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(long timespan, java.util.concurrent.TimeUnit unit, int count)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `\u003cTOpening,TClosing\u003e Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(Observable\u003c? extends TOpening\u003e bufferOpenings, Func1\u003c? super TOpening,? extends Observable\u003c? extends TClosing\u003e\u003e bufferClosingSelector)`\n- [x] `\u003cB\u003e Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(Observable\u003cB\u003e boundary)`\n- [x] `\u003cB\u003e Observable\u003cjava.util.List\u003cT\u003e\u003e buffer(Observable\u003cB\u003e boundary, int initialCapacity)`\n- [x] `Observable\u003cT\u003e cache()`\n- [x] `Observable\u003cT\u003e cache(int capacity)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e cast(java.lang.Class\u003cR\u003e klass)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e collect(Func0\u003cR\u003e stateFactory, Action2\u003cR,? super T\u003e collector)`\n- [x] `static \u003cT,R\u003e Observable\u003cR\u003e combineLatest(java.util.List\u003c? extends Observable\u003c? extends T\u003e\u003e sources, FuncN\u003c? extends R\u003e combineFunction)`\n- [x] `static \u003cT1,T2,R\u003e Observable\u003cR\u003e combineLatest(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Func2\u003c? super T1,? super T2,? extends R\u003e combineFunction)`\n- [x] `static \u003cT1,T2,T3,R\u003e Observable\u003cR\u003e combineLatest(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Func3\u003c? super T1,? super T2,? super T3,? extends R\u003e combineFunction)`\n- [x] `static \u003cT1,T2,T3,T4,R\u003e Observable\u003cR\u003e combineLatest(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Func4\u003c? super T1,? super T2,? super T3,? super T4,? extends R\u003e combineFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,R\u003e Observable\u003cR\u003e combineLatest(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Func5\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? extends R\u003e combineFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,T6,R\u003e Observable\u003cR\u003e combineLatest(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Observable\u003c? extends T6\u003e o6, Func6\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R\u003e combineFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,T6,T7,R\u003e Observable\u003cR\u003e combineLatest(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Observable\u003c? extends T6\u003e o6, Observable\u003c? extends T7\u003e o7, Func7\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R\u003e combineFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,T6,T7,T8,R\u003e Observable\u003cR\u003e combineLatest(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Observable\u003c? extends T6\u003e o6, Observable\u003c? extends T7\u003e o7, Observable\u003c? extends T8\u003e o8, Func8\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R\u003e combineFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,T6,T7,T8,T9,R\u003e Observable\u003cR\u003e combineLatest(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Observable\u003c? extends T6\u003e o6, Observable\u003c? extends T7\u003e o7, Observable\u003c? extends T8\u003e o8, Observable\u003c? extends T9\u003e o9, Func9\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R\u003e combineFunction)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e compose(Observable.Transformer\u003c? super T,? extends R\u003e transformer)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends Observable\u003c? extends T\u003e\u003e observables)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7, Observable\u003c? extends T\u003e t8)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e concat(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7, Observable\u003c? extends T\u003e t8, Observable\u003c? extends T\u003e t9)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e concatMap(Func1\u003c? super T,? extends Observable\u003c? extends R\u003e\u003e func)`\n- [x] `Observable\u003cT\u003e concatWith(Observable\u003c? extends T\u003e t1)`\n- [x] `Observable\u003cjava.lang.Boolean\u003e contains(java.lang.Object element)`\n- [x] `Observable\u003cjava.lang.Integer\u003e count()`\n- [x] `Observable\u003cjava.lang.Long\u003e countLong()`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e create(Observable.OnSubscribe\u003cT\u003e f)`\n- [x] `\u003cU\u003e Observable\u003cT\u003e debounce(Func1\u003c? super T,? extends Observable\u003cU\u003e\u003e debounceSelector)`\n- [x] `Observable\u003cT\u003e debounce(long timeout, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e debounce(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e defaultIfEmpty(T defaultValue)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e defer(Func0\u003cObservable\u003cT\u003e\u003e observableFactory)`\n- [x] `\u003cU,V\u003e Observable\u003cT\u003e delay(Func0\u003c? extends Observable\u003cU\u003e\u003e subscriptionDelay, Func1\u003c? super T,? extends Observable\u003cV\u003e\u003e itemDelay)`\n- [x] `\u003cU\u003e Observable\u003cT\u003e delay(Func1\u003c? super T,? extends Observable\u003cU\u003e\u003e itemDelay)`\n- [x] `Observable\u003cT\u003e delay(long delay, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e delay(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `\u003cU\u003e Observable\u003cT\u003e delaySubscription(Func0\u003c? extends Observable\u003cU\u003e\u003e subscriptionDelay)`\n- [x] `Observable\u003cT\u003e delaySubscription(long delay, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e delaySubscription(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `\u003cT2\u003e Observable\u003cT2\u003e dematerialize()`\n- [x] `Observable\u003cT\u003e distinct()`\n- [x] `\u003cU\u003e Observable\u003cT\u003e distinct(Func1\u003c? super T,? extends U\u003e keySelector)`\n- [x] `Observable\u003cT\u003e distinctUntilChanged()`\n- [x] `\u003cU\u003e Observable\u003cT\u003e distinctUntilChanged(Func1\u003c? super T,? extends U\u003e keySelector)`\n- [x] `Observable\u003cT\u003e doOnCompleted(Action0 onCompleted)`\n- [x] `Observable\u003cT\u003e doOnEach(Action1\u003cNotification\u003c? super T\u003e\u003e onNotification)`\n- [x] `Observable\u003cT\u003e doOnEach(Observer\u003c? super T\u003e observer)`\n- [x] `Observable\u003cT\u003e doOnError(Action1\u003cjava.lang.Throwable\u003e onError)`\n- [x] `Observable\u003cT\u003e doOnNext(Action1\u003c? super T\u003e onNext)`\n- [x] `Observable\u003cT\u003e doOnRequest(Action1\u003cjava.lang.Long\u003e onRequest)`\n- [x] `Observable\u003cT\u003e doOnSubscribe(Action0 subscribe)`\n- [x] `Observable\u003cT\u003e doOnTerminate(Action0 onTerminate)`\n- [x] `Observable\u003cT\u003e doOnUnsubscribe(Action0 unsubscribe)`\n- [x] `Observable\u003cT\u003e elementAt(int index)`\n- [x] `Observable\u003cT\u003e elementAtOrDefault(int index, T defaultValue)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e empty()`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e error(java.lang.Throwable exception)`\n- [x] `Observable\u003cjava.lang.Boolean\u003e exists(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e filter(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e finallyDo(Action0 action)`\n- [x] `Observable\u003cT\u003e first()`\n- [x] `Observable\u003cT\u003e first(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e firstOrDefault(T defaultValue)`\n- [x] `Observable\u003cT\u003e firstOrDefault(T defaultValue, Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e flatMap(Func1\u003c? super T,? extends Observable\u003c? extends R\u003e\u003e func)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e flatMap(Func1\u003c? super T,? extends Observable\u003c? extends R\u003e\u003e onNext, Func1\u003c? super java.lang.Throwable,? extends Observable\u003c? extends R\u003e\u003e onError, Func0\u003c? extends Observable\u003c? extends R\u003e\u003e onCompleted)`\n- [x] `\u003cU,R\u003e Observable\u003cR\u003e flatMap(Func1\u003c? super T,? extends Observable\u003c? extends U\u003e\u003e collectionSelector, Func2\u003c? super T,? super U,? extends R\u003e resultSelector)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e flatMapIterable(Func1\u003c? super T,? extends java.lang.Iterable\u003c? extends R\u003e\u003e collectionSelector)`\n- [x] `\u003cU,R\u003e Observable\u003cR\u003e flatMapIterable(Func1\u003c? super T,? extends java.lang.Iterable\u003c? extends U\u003e\u003e collectionSelector, Func2\u003c? super T,? super U,? extends R\u003e resultSelector)`\n- [x] `void forEach(Action1\u003c? super T\u003e onNext)`\n- [x] `void forEach(Action1\u003c? super T\u003e onNext, Action1\u003cjava.lang.Throwable\u003e onError)`\n- [x] `void forEach(Action1\u003c? super T\u003e onNext, Action1\u003cjava.lang.Throwable\u003e onError, Action0 onComplete)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e from(java.util.concurrent.Future\u003c? extends T\u003e future)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e from(java.util.concurrent.Future\u003c? extends T\u003e future, long timeout, java.util.concurrent.TimeUnit unit)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e from(java.util.concurrent.Future\u003c? extends T\u003e future, Scheduler scheduler)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e from(java.lang.Iterable\u003c? extends T\u003e iterable)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e from(T[] array)`\n- [x] `\u003cK\u003e Observable\u003cGroupedObservable\u003cK,T\u003e\u003e groupBy(Func1\u003c? super T,? extends K\u003e keySelector)`\n- [x] `\u003cK,R\u003e Observable\u003cGroupedObservable\u003cK,R\u003e\u003e groupBy(Func1\u003c? super T,? extends K\u003e keySelector, Func1\u003c? super T,? extends R\u003e elementSelector)`\n- [x] `\u003cT2,D1,D2,R\u003e Observable\u003cR\u003e groupJoin(Observable\u003cT2\u003e right, Func1\u003c? super T,? extends Observable\u003cD1\u003e\u003e leftDuration, Func1\u003c? super T2,? extends Observable\u003cD2\u003e\u003e rightDuration, Func2\u003c? super T,? super Observable\u003cT2\u003e,? extends R\u003e resultSelector)`\n- [x] `Observable\u003cT\u003e ignoreElements()`\n- [x] `static Observable\u003cjava.lang.Long\u003e interval(long interval, java.util.concurrent.TimeUnit unit)`\n- [x] `static Observable\u003cjava.lang.Long\u003e interval(long interval, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cjava.lang.Boolean\u003e isEmpty()`\n- [x] `\u003cTRight,TLeftDuration,TRightDuration,R\u003e Observable\u003cR\u003e join(Observable\u003cTRight\u003e right, Func1\u003cT,Observable\u003cTLeftDuration\u003e\u003e leftDurationSelector, Func1\u003cTRight,Observable\u003cTRightDuration\u003e\u003e rightDurationSelector, Func2\u003cT,TRight,R\u003e resultSelector)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T value)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2, T t3)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2, T t3, T t4)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2, T t3, T t4, T t5)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2, T t3, T t4, T t5, T t6)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2, T t3, T t4, T t5, T t6, T t7)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10)`\n- [x] `Observable\u003cT\u003e last()`\n- [x] `Observable\u003cT\u003e last(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e lastOrDefault(T defaultValue)`\n- [x] `Observable\u003cT\u003e lastOrDefault(T defaultValue, Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e lift(Observable.Operator\u003c? extends R,? super T\u003e lift)`\n- [x] `Observable\u003cT\u003e limit(int num)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e map(Func1\u003c? super T,? extends R\u003e func)`\n- [x] `Observable\u003cNotification\u003cT\u003e\u003e materialize()`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(java.lang.Iterable\u003c? extends Observable\u003c? extends T\u003e\u003e sequences)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(java.lang.Iterable\u003c? extends Observable\u003c? extends T\u003e\u003e sequences, int maxConcurrent)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends Observable\u003c? extends T\u003e\u003e source)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends Observable\u003c? extends T\u003e\u003e source, int maxConcurrent)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e[] sequences)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2,`Observable\u003c? extends T\u003e t3)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7, Observable\u003c? extends T\u003e t8)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e merge(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7, Observable\u003c? extends T\u003e t8, Observable\u003c? extends T\u003e t9)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends Observable\u003c? extends T\u003e\u003e source)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7, Observable\u003c? extends T\u003e t8)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e mergeDelayError(Observable\u003c? extends T\u003e t1, Observable\u003c? extends T\u003e t2, Observable\u003c? extends T\u003e t3, Observable\u003c? extends T\u003e t4, Observable\u003c? extends T\u003e t5, Observable\u003c? extends T\u003e t6, Observable\u003c? extends T\u003e t7, Observable\u003c? extends T\u003e t8, Observable\u003c? extends T\u003e t9)`\n- [x] `Observable\u003cT\u003e mergeWith(Observable\u003c? extends T\u003e t1)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e nest()`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e never()`\n- [x] `Observable\u003cT\u003e observeOn(Scheduler scheduler)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e ofType(java.lang.Class\u003cR\u003e klass)`\n- [x] `Observable\u003cT\u003e onBackpressureBuffer()`\n- [x] `Observable\u003cT\u003e onBackpressureBuffer(long capacity)`\n- [x] `Observable\u003cT\u003e onBackpressureDrop()`\n- [x] `Observable\u003cT\u003e onErrorResumeNext(Func1\u003cjava.lang.Throwable,? extends Observable\u003c? extends T\u003e\u003e resumeFunction)`\n- [x] `Observable\u003cT\u003e onErrorResumeNext(Observable\u003c? extends T\u003e resumeSequence)`\n- [x] `Observable\u003cT\u003e onErrorReturn(Func1\u003cjava.lang.Throwable,? extends T\u003e resumeFunction)`\n- [x] `Observable\u003cT\u003e onExceptionResumeNext(Observable\u003c? extends T\u003e resumeSequence)`\n- [x] `ConnectableObservable\u003cT\u003e publish()`\n- [x] `\u003cR\u003e Observable\u003cR\u003e publish(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector)`\n- [x] `static Observable\u003cjava.lang.Integer\u003e range(int start, int count)`\n- [x] `static Observable\u003cjava.lang.Integer\u003e range(int start, int count, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e reduce(Func2\u003cT,T,T\u003e accumulator)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e reduce(R initialValue, Func2\u003cR,? super T,R\u003e accumulator)`\n- [x] `Observable\u003cT\u003e repeat()`\n- [x] `Observable\u003cT\u003e repeat(long count)`\n- [x] `Observable\u003cT\u003e repeat(long count, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e repeat(Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e repeatWhen(Func1\u003c? super Observable\u003c? extends java.lang.Void\u003e,? extends Observable\u003c?\u003e\u003e notificationHandler)`\n- [x] `Observable\u003cT\u003e repeatWhen(Func1\u003c? super Observable\u003c? extends java.lang.Void\u003e,? extends Observable\u003c?\u003e\u003e notificationHandler, Scheduler scheduler)`\n- [x] `ConnectableObservable\u003cT\u003e replay()`\n- [x] `\u003cR\u003e Observable\u003cR\u003e replay(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e replay(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector, int bufferSize)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e replay(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e replay(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e replay(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector, int bufferSize, Scheduler scheduler)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e replay(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector, long time, java.util.concurrent.TimeUnit unit)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e replay(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e replay(Func1\u003c? super Observable\u003cT\u003e,? extends Observable\u003cR\u003e\u003e selector, Scheduler scheduler)`\n- [x] `ConnectableObservable\u003cT\u003e replay(int bufferSize)`\n- [x] `ConnectableObservable\u003cT\u003e replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit)`\n- [x] `ConnectableObservable\u003cT\u003e replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `ConnectableObservable\u003cT\u003e replay(int bufferSize, Scheduler scheduler)`\n- [x] `ConnectableObservable\u003cT\u003e replay(long time, java.util.concurrent.TimeUnit unit)`\n- [x] `ConnectableObservable\u003cT\u003e replay(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `ConnectableObservable\u003cT\u003e replay(Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e retry()`\n- [x] `Observable\u003cT\u003e retry(Func2\u003cjava.lang.Integer,java.lang.Throwable,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e retry(long count)`\n- [x] `Observable\u003cT\u003e retryWhen(Func1\u003c? super Observable\u003c? extends java.lang.Throwable\u003e,? extends Observable\u003c?\u003e\u003e notificationHandler)`\n- [x] `Observable\u003cT\u003e retryWhen(Func1\u003c? super Observable\u003c? extends java.lang.Throwable\u003e,? extends Observable\u003c?\u003e\u003e notificationHandler, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e sample(long period, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e sample(long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `\u003cU\u003e Observable\u003cT\u003e sample(Observable\u003cU\u003e sampler)`\n- [x] `Observable\u003cT\u003e scan(Func2\u003cT,T,T\u003e accumulator)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e scan(R initialValue, Func2\u003cR,? super T,R\u003e accumulator)`\n- [x] `static \u003cT\u003e Observable\u003cjava.lang.Boolean\u003e sequenceEqual(Observable\u003c? extends T\u003e first, Observable\u003c? extends T\u003e second)`\n- [x] `static \u003cT\u003e Observable\u003cjava.lang.Boolean\u003e sequenceEqual(Observable\u003c? extends T\u003e first, Observable\u003c? extends T\u003e second, Func2\u003c? super T,? super T,java.lang.Boolean\u003e equality)`\n- [x] `Observable\u003cT\u003e serialize()`\n- [x] `Observable\u003cT\u003e share()`\n- [x] `Observable\u003cT\u003e single()`\n- [x] `Observable\u003cT\u003e single(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e singleOrDefault(T defaultValue)`\n- [x] `Observable\u003cT\u003e singleOrDefault(T defaultValue, Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e skip(int num)`\n- [x] `Observable\u003cT\u003e skip(long time, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e skip(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e skipLast(int count)`\n- [x] `Observable\u003cT\u003e skipLast(long time, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e skipLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `\u003cU\u003e Observable\u003cT\u003e skipUntil(Observable\u003cU\u003e other)`\n- [x] `Observable\u003cT\u003e skipWhile(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e startWith(java.lang.Iterable\u003cT\u003e values)`\n- [x] `Observable\u003cT\u003e startWith(Observable\u003cT\u003e values)`\n- [x] `Observable\u003cT\u003e startWith(T t1)`\n- [x] `Observable\u003cT\u003e startWith(T t1, T t2)`\n- [x] `Observable\u003cT\u003e startWith(T t1, T t2, T t3)`\n- [x] `Observable\u003cT\u003e startWith(T t1, T t2, T t3, T t4)`\n- [x] `Observable\u003cT\u003e startWith(T t1, T t2, T t3, T t4, T t5)`\n- [x] `Observable\u003cT\u003e startWith(T t1, T t2, T t3, T t4, T t5, T t6)`\n- [x] `Observable\u003cT\u003e startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7)`\n- [x] `Observable\u003cT\u003e startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8)`\n- [x] `Observable\u003cT\u003e startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9)`\n- [x] `Subscription subscribe()`\n- [x] `Subscription subscribe(Action1\u003c? super T\u003e onNext)`\n- [x] `Subscription subscribe(Action1\u003c? super T\u003e onNext, Action1\u003cjava.lang.Throwable\u003e onError)`\n- [x] `Subscription subscribe(Action1\u003c? super T\u003e onNext, Action1\u003cjava.lang.Throwable\u003e onError, Action0 onComplete)`\n- [x] `Subscription subscribe(Observer\u003c? super T\u003e observer)`\n- [x] `Subscription subscribe(Subscriber\u003c? super T\u003e subscriber)`\n- [x] `Observable\u003cT\u003e subscribeOn(Scheduler scheduler)`\n- [x] `\u003cR\u003e Observable\u003cR\u003e switchMap(Func1\u003c? super T,? extends Observable\u003c? extends R\u003e\u003e func)`\n- [x] `static \u003cT\u003e Observable\u003cT\u003e switchOnNext(Observable\u003c? extends Observable\u003c? extends T\u003e\u003e sequenceOfSequences)`\n- [x] `Observable\u003cT\u003e take(int num)`\n- [x] `Observable\u003cT\u003e take(long time, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e take(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e takeFirst(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e takeLast(int count)`\n- [x] `Observable\u003cT\u003e takeLast(int count, long time, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e takeLast(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e takeLast(long time, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e takeLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e takeLastBuffer(int count)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e takeLastBuffer(long time, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e takeLastBuffer(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e takeUntil(Func1\u003c? super T,java.lang.Boolean\u003e stopPredicate)`\n- [x] `\u003cE\u003e Observable\u003cT\u003e takeUntil(Observable\u003c? extends E\u003e other)`\n- [x] `Observable\u003cT\u003e takeWhile(Func1\u003c? super T,java.lang.Boolean\u003e predicate)`\n- [x] `Observable\u003cT\u003e throttleFirst(long windowDuration, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e throttleFirst(long skipDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cT\u003e throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cTimeInterval\u003cT\u003e\u003e timeInterval()`\n- [x] `Observable\u003cTimeInterval\u003cT\u003e\u003e timeInterval(Scheduler scheduler)`\n- [x] `\u003cU,V\u003e Observable\u003cT\u003e timeout(Func0\u003c? extends Observable\u003cU\u003e\u003e firstTimeoutSelector, Func1\u003c? super T,? extends Observable\u003cV\u003e\u003e timeoutSelector)`\n- [x] `\u003cU,V\u003e Observable\u003cT\u003e timeout(Func0\u003c? extends Observable\u003cU\u003e\u003e firstTimeoutSelector, Func1\u003c? super T,? extends Observable\u003cV\u003e\u003e timeoutSelector, Observable\u003c? extends T\u003e other)`\n- [x] `\u003cV\u003e Observable\u003cT\u003e timeout(Func1\u003c? super T,? extends Observable\u003cV\u003e\u003e timeoutSelector)`\n- [x] `\u003cV\u003e Observable\u003cT\u003e timeout(Func1\u003c? super T,? extends Observable\u003cV\u003e\u003e timeoutSelector, Observable\u003c? extends T\u003e other)`\n- [x] `Observable\u003cT\u003e timeout(long timeout, java.util.concurrent.TimeUnit timeUnit)`\n- [x] `Observable\u003cT\u003e timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable\u003c? extends T\u003e other)`\n- [x] `Observable\u003cT\u003e timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable\u003c? extends T\u003e other, Scheduler scheduler)`\n- [x] `Observable\u003cT\u003e timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Scheduler scheduler)`\n- [x] `static Observable\u003cjava.lang.Long\u003e timer(long initialDelay, long period, java.util.concurrent.TimeUnit unit)`\n- [x] `static Observable\u003cjava.lang.Long\u003e timer(long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `static Observable\u003cjava.lang.Long\u003e timer(long delay, java.util.concurrent.TimeUnit unit)`\n- [x] `static Observable\u003cjava.lang.Long\u003e timer(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cTimestamped\u003cT\u003e\u003e timestamp()`\n- [x] `Observable\u003cTimestamped\u003cT\u003e\u003e timestamp(Scheduler scheduler)`\n- [x] `BlockingObservable\u003cT\u003e toBlocking()`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e toList()`\n- [x] `\u003cK\u003e Observable\u003cjava.util.Map\u003cK,T\u003e\u003e toMap(Func1\u003c? super T,? extends K\u003e keySelector)`\n- [x] `\u003cK,V\u003e Observable\u003cjava.util.Map\u003cK,V\u003e\u003e toMap(Func1\u003c? super T,? extends K\u003e keySelector, Func1\u003c? super T,? extends V\u003e valueSelector)`\n- [x] `\u003cK,V\u003e Observable\u003cjava.util.Map\u003cK,V\u003e\u003e toMap(Func1\u003c? super T,? extends K\u003e keySelector, Func1\u003c? super T,? extends V\u003e valueSelector, Func0\u003c? extends java.util.Map\u003cK,V\u003e\u003e mapFactory)`\n- [x] `\u003cK\u003e Observable\u003cjava.util.Map\u003cK,java.util.Collection\u003cT\u003e\u003e\u003e toMultimap(Func1\u003c? super T,? extends K\u003e keySelector)`\n- [x] `\u003cK,V\u003e Observable\u003cjava.util.Map\u003cK,java.util.Collection\u003cV\u003e\u003e\u003e toMultimap(Func1\u003c? super T,? extends K\u003e keySelector, Func1\u003c? super T,? extends V\u003e valueSelector)`\n- [x] `\u003cK,V\u003e Observable\u003cjava.util.Map\u003cK,java.util.Collection\u003cV\u003e\u003e\u003e toMultimap(Func1\u003c? super T,? extends K\u003e keySelector, Func1\u003c? super T,? extends V\u003e valueSelector, Func0\u003c? extends java.util.Map\u003cK,java.util.Collection\u003cV\u003e\u003e\u003e mapFactory)`\n- [x] `\u003cK,V\u003e Observable\u003cjava.util.Map\u003cK,java.util.Collection\u003cV\u003e\u003e\u003e toMultimap(Func1\u003c? super T,? extends K\u003e keySelector, Func1\u003c? super T,? extends V\u003e valueSelector, Func0\u003c? extends java.util.Map\u003cK,java.util.Collection\u003cV\u003e\u003e\u003e mapFactory, Func1\u003c? super K,? extends java.util.Collection\u003cV\u003e\u003e collectionFactory)`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e toSortedList()`\n- [x] `Observable\u003cjava.util.List\u003cT\u003e\u003e toSortedList(Func2\u003c? super T,? super T,java.lang.Integer\u003e sortFunction)`\n- [x] `Subscription unsafeSubscribe(Subscriber\u003c? super T\u003e subscriber)`\n- [x] `Observable\u003cT\u003e unsubscribeOn(Scheduler scheduler)`\n- [x] `static \u003cT,Resource\u003e Observable\u003cT\u003e using(Func0\u003cResource\u003e resourceFactory, Func1\u003c? super Resource,? extends Observable\u003c? extends T\u003e\u003e observableFactory, Action1\u003c? super Resource\u003e disposeAction)`\n- [x] `\u003cTClosing\u003e Observable\u003cObservable\u003cT\u003e\u003e window(Func0\u003c? extends Observable\u003c? extends TClosing\u003e\u003e closingSelector)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(int count)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(int count, int skip)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(long timespan, java.util.concurrent.TimeUnit unit)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(long timespan, java.util.concurrent.TimeUnit unit, int count)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler)`\n- [x] `Observable\u003cObservable\u003cT\u003e\u003e window(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`\n- [x] `\u003cTOpening,TClosing\u003e Observable\u003cObservable\u003cT\u003e\u003e window(Observable\u003c? extends TOpening\u003e windowOpenings, Func1\u003c? super TOpening,? extends Observable\u003c? extends TClosing\u003e\u003e closingSelector)`\n- [x] `\u003cU\u003e Observable\u003cObservable\u003cT\u003e\u003e window(Observable\u003cU\u003e boundary)`\n- [x] `static \u003cR\u003e Observable\u003cR\u003e zip(java.lang.Iterable\u003c? extends Observable\u003c?\u003e\u003e ws, FuncN\u003c? extends R\u003e zipFunction)`\n- [x] `static \u003cR\u003e Observable\u003cR\u003e zip(Observable\u003c? extends Observable\u003c?\u003e\u003e ws, FuncN\u003c? extends R\u003e zipFunction)`\n- [x] `static \u003cT1,T2,R\u003e Observable\u003cR\u003e zip(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Func2\u003c? super T1,? super T2,? extends R\u003e zipFunction)`\n- [x] `static \u003cT1,T2,T3,R\u003e Observable\u003cR\u003e zip(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Func3\u003c? super T1,? super T2,? super T3,? extends R\u003e zipFunction)`\n- [x] `static \u003cT1,T2,T3,T4,R\u003e Observable\u003cR\u003e zip(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Func4\u003c? super T1,? super T2,? super T3,? super T4,? extends R\u003e zipFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,R\u003e Observable\u003cR\u003e zip(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Func5\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? extends R\u003e zipFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,T6,R\u003e Observable\u003cR\u003e zip(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Observable\u003c? extends T6\u003e o6, Func6\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R\u003e zipFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,T6,T7,R\u003e Observable\u003cR\u003e zip(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Observable\u003c? extends T6\u003e o6, Observable\u003c? extends T7\u003e o7, Func7\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R\u003e zipFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,T6,T7,T8,R\u003e Observable\u003cR\u003e zip(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Observable\u003c? extends T6\u003e o6, Observable\u003c? extends T7\u003e o7, Observable\u003c? extends T8\u003e o8, Func8\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R\u003e zipFunction)`\n- [x] `static \u003cT1,T2,T3,T4,T5,T6,T7,T8,T9,R\u003e Observable\u003cR\u003e zip(Observable\u003c? extends T1\u003e o1, Observable\u003c? extends T2\u003e o2, Observable\u003c? extends T3\u003e o3, Observable\u003c? extends T4\u003e o4, Observable\u003c? extends T5\u003e o5, Observable\u003c? extends T6\u003e o6, Observable\u003c? extends T7\u003e o7, Observable\u003c? extends T8\u003e o8, Observable\u003c? extends T9\u003e o9, Func9\u003c? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R\u003e zipFunction)`\n- [x] `\u003cT2,R\u003e Observable\u003cR\u003e zipWith(java.lang.Iterable\u003c? extends T2\u003e other, Func2\u003c? super T,? super T2,? extends R\u003e zipFunction)`\n- [x] `\u003cT2,R\u003e Observable\u003cR\u003e zipWith(Observable\u003c? extends T2\u003e other, Func2\u003c? super T,? super T2,? extends R\u003e zipFunction)``\n","author":{"url":"https://github.com/Froussios","@type":"Person","name":"Froussios"},"datePublished":"2015-04-22T17:05:27.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":1},"url":"https://github.com/2/Intro-To-RxJava/issues/2"}
| route-pattern | /_view_fragments/issues/show/:user_id/:repository/:id/issue_layout(.:format) |
| route-controller | voltron_issues_fragments |
| route-action | issue_layout |
| fetch-nonce | v2:54851909-d170-ea83-f8eb-8b8378b912a6 |
| current-catalog-service-hash | 81bb79d38c15960b92d99bca9288a9108c7a47b18f2423d0f6438c5b7bcd2114 |
| request-id | C308:28B5F5:73621E:9E23A6:6A55A7DF |
| html-safe-nonce | b648e53de55aeedb73d285bbdcc3350eac1f41000578c63b64f6cadc821b5ed5 |
| visitor-payload | eyJyZWZlcnJlciI6IiIsInJlcXVlc3RfaWQiOiJDMzA4OjI4QjVGNTo3MzYyMUU6OUUyM0E2OjZBNTVBN0RGIiwidmlzaXRvcl9pZCI6IjM1MzA4NDU1MzAwOTkxMzIzODMiLCJyZWdpb25fZWRnZSI6ImlhZCIsInJlZ2lvbl9yZW5kZXIiOiJpYWQifQ== |
| visitor-hmac | 5353303bc02d4173d4362b70905409e85a23935adb535913d886e26e5377b656 |
| hovercard-subject-tag | issue:70181303 |
| github-keyboard-shortcuts | repository,issues,copilot |
| google-site-verification | Apib7-x98H0j5cPqHWwSMm6dNU4GmODRoqxLiDzdx9I |
| octolytics-url | https://collector.github.com/github/collect |
| analytics-location | / |
| fb:app_id | 1401488693436528 |
| apple-itunes-app | app-id=1477376905, app-argument=https://github.com/_view_fragments/issues/show/Froussios/Intro-To-RxJava/2/issue_layout |
| twitter:image | https://opengraph.githubassets.com/963e241031a4653ffccf9ae304e951aa34fcde08cee9a08c42fccb681b265b68/Froussios/Intro-To-RxJava/issues/2 |
| twitter:card | summary_large_image |
| og:image | https://opengraph.githubassets.com/963e241031a4653ffccf9ae304e951aa34fcde08cee9a08c42fccb681b265b68/Froussios/Intro-To-RxJava/issues/2 |
| og:image:alt | Operators covered Observable |
| og:image:width | 1200 |
| og:image:height | 600 |
| og:site_name | GitHub |
| og:type | object |
| og:author:username | Froussios |
| hostname | github.com |
| expected-hostname | github.com |
| None | b5665c84831ed9ac4fb79519c16c9c5580ba8092fb8bb6e3e72972ec7197348e |
| turbo-cache-control | no-preview |
| go-import | github.com/Froussios/Intro-To-RxJava git https://github.com/Froussios/Intro-To-RxJava.git |
| octolytics-dimension-user_id | 1633816 |
| octolytics-dimension-user_login | Froussios |
| octolytics-dimension-repository_id | 32989617 |
| octolytics-dimension-repository_nwo | Froussios/Intro-To-RxJava |
| octolytics-dimension-repository_public | true |
| octolytics-dimension-repository_is_fork | false |
| octolytics-dimension-repository_network_root_id | 32989617 |
| octolytics-dimension-repository_network_root_nwo | Froussios/Intro-To-RxJava |
| turbo-body-classes | logged-out env-production page-responsive |
| disable-turbo | false |
| browser-stats-url | https://api.github.com/_private/browser/stats |
| browser-errors-url | https://api.github.com/_private/browser/errors |
| release | 653fccf1e27344851c0d3de3fa6faa526197f072 |
| ui-target | full |
| theme-color | #1e2327 |
| color-scheme | light dark |
Links:
Viewport: width=device-width