René's URL Explorer Experiment


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 all(Func1 predicate) static Observable amb(java.lang.Iterable> sources) static Observable amb(Observable

Open Graph Description: Operators covered Observable all(Func1 predicate) static Observable amb(java.lang.Iterable> sources) static ...

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

direct link

Domain: github.com


Hey, it has json ld scripts:
{"@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-controllervoltron_issues_fragments
route-actionissue_layout
fetch-noncev2:54851909-d170-ea83-f8eb-8b8378b912a6
current-catalog-service-hash81bb79d38c15960b92d99bca9288a9108c7a47b18f2423d0f6438c5b7bcd2114
request-idC308:28B5F5:73621E:9E23A6:6A55A7DF
html-safe-nonceb648e53de55aeedb73d285bbdcc3350eac1f41000578c63b64f6cadc821b5ed5
visitor-payloadeyJyZWZlcnJlciI6IiIsInJlcXVlc3RfaWQiOiJDMzA4OjI4QjVGNTo3MzYyMUU6OUUyM0E2OjZBNTVBN0RGIiwidmlzaXRvcl9pZCI6IjM1MzA4NDU1MzAwOTkxMzIzODMiLCJyZWdpb25fZWRnZSI6ImlhZCIsInJlZ2lvbl9yZW5kZXIiOiJpYWQifQ==
visitor-hmac5353303bc02d4173d4362b70905409e85a23935adb535913d886e26e5377b656
hovercard-subject-tagissue:70181303
github-keyboard-shortcutsrepository,issues,copilot
google-site-verificationApib7-x98H0j5cPqHWwSMm6dNU4GmODRoqxLiDzdx9I
octolytics-urlhttps://collector.github.com/github/collect
analytics-location///voltron/issues_fragments/issue_layout
fb:app_id1401488693436528
apple-itunes-appapp-id=1477376905, app-argument=https://github.com/_view_fragments/issues/show/Froussios/Intro-To-RxJava/2/issue_layout
twitter:imagehttps://opengraph.githubassets.com/963e241031a4653ffccf9ae304e951aa34fcde08cee9a08c42fccb681b265b68/Froussios/Intro-To-RxJava/issues/2
twitter:cardsummary_large_image
og:imagehttps://opengraph.githubassets.com/963e241031a4653ffccf9ae304e951aa34fcde08cee9a08c42fccb681b265b68/Froussios/Intro-To-RxJava/issues/2
og:image:altOperators covered Observable all(Func1 predicate) static Observable amb(java.lang.Iterable> sources) static ...
og:image:width1200
og:image:height600
og:site_nameGitHub
og:typeobject
og:author:usernameFroussios
hostnamegithub.com
expected-hostnamegithub.com
Noneb5665c84831ed9ac4fb79519c16c9c5580ba8092fb8bb6e3e72972ec7197348e
turbo-cache-controlno-preview
go-importgithub.com/Froussios/Intro-To-RxJava git https://github.com/Froussios/Intro-To-RxJava.git
octolytics-dimension-user_id1633816
octolytics-dimension-user_loginFroussios
octolytics-dimension-repository_id32989617
octolytics-dimension-repository_nwoFroussios/Intro-To-RxJava
octolytics-dimension-repository_publictrue
octolytics-dimension-repository_is_forkfalse
octolytics-dimension-repository_network_root_id32989617
octolytics-dimension-repository_network_root_nwoFroussios/Intro-To-RxJava
turbo-body-classeslogged-out env-production page-responsive
disable-turbofalse
browser-stats-urlhttps://api.github.com/_private/browser/stats
browser-errors-urlhttps://api.github.com/_private/browser/errors
release653fccf1e27344851c0d3de3fa6faa526197f072
ui-targetfull
theme-color#1e2327
color-schemelight dark

Links:

Skip to contenthttps://github.com/Froussios/Intro-To-RxJava/issues/2#start-of-content
https://github.com/
Sign in https://github.com/login?return_to=https%3A%2F%2Fgithub.com%2FFroussios%2FIntro-To-RxJava%2Fissues%2F2
GitHub CopilotWrite better code with AIhttps://github.com/features/copilot
GitHub Copilot appDirect agents from issue to mergehttps://github.com/features/ai/github-app
MCP RegistryNewIntegrate external toolshttps://github.com/mcp
ActionsAutomate any workflowhttps://github.com/features/actions
CodespacesInstant dev environmentshttps://github.com/features/codespaces
IssuesPlan and track workhttps://github.com/features/issues
Code ReviewManage code changeshttps://github.com/features/code-review
GitHub Advanced SecurityFind and fix vulnerabilitieshttps://github.com/security/advanced-security
Code securitySecure your code as you buildhttps://github.com/security/advanced-security/code-security
Secret protectionStop leaks before they starthttps://github.com/security/advanced-security/secret-protection
Why GitHubhttps://github.com/why-github
Documentationhttps://docs.github.com
Bloghttps://github.blog
Changeloghttps://github.blog/changelog
Marketplacehttps://github.com/marketplace
View all featureshttps://github.com/features
Enterpriseshttps://github.com/enterprise
Small and medium teamshttps://github.com/team
Startupshttps://github.com/enterprise/startups
Nonprofitshttps://github.com/solutions/industry/nonprofits
App Modernizationhttps://github.com/solutions/use-case/app-modernization
DevSecOpshttps://github.com/solutions/use-case/devsecops
DevOpshttps://github.com/solutions/use-case/devops
CI/CDhttps://github.com/solutions/use-case/ci-cd
View all use caseshttps://github.com/solutions/use-case
Healthcarehttps://github.com/solutions/industry/healthcare
Financial serviceshttps://github.com/solutions/industry/financial-services
Manufacturinghttps://github.com/solutions/industry/manufacturing
Governmenthttps://github.com/solutions/industry/government
View all industrieshttps://github.com/solutions/industry
View all solutionshttps://github.com/solutions
AIhttps://github.com/resources/articles?topic=ai
Software Developmenthttps://github.com/resources/articles?topic=software-development
DevOpshttps://github.com/resources/articles?topic=devops
Securityhttps://github.com/resources/articles?topic=security
View all topicshttps://github.com/resources/articles
Customer storieshttps://github.com/customer-stories
Events & webinarshttps://github.com/resources/events
Ebooks & reportshttps://github.com/resources/whitepapers
Business insightshttps://github.com/solutions/executive-insights
GitHub Skillshttps://skills.github.com
Documentationhttps://docs.github.com
Customer supporthttps://support.github.com
Community forumhttps://github.com/orgs/community/discussions
Trust centerhttps://github.com/trust-center
Partnershttps://github.com/partners
View all resourceshttps://github.com/resources
GitHub SponsorsFund open source developershttps://github.com/open-source/sponsors
Security Labhttps://securitylab.github.com
Maintainer Communityhttps://maintainers.github.com
Acceleratorhttps://github.com/open-source/accelerator
GitHub Starshttps://stars.github.com
Archive Programhttps://archiveprogram.github.com
Topicshttps://github.com/topics
Trendinghttps://github.com/trending
Collectionshttps://github.com/collections
Enterprise platformAI-powered developer platformhttps://github.com/enterprise
GitHub Advanced SecurityEnterprise-grade security featureshttps://github.com/security/advanced-security
Copilot for BusinessEnterprise-grade AI featureshttps://github.com/features/copilot/copilot-business
Premium SupportEnterprise-grade 24/7 supporthttps://github.com/enterprise/premium-support
Pricinghttps://github.com/pricing
Search syntax tipshttps://docs.github.com/search-github/github-code-search/understanding-github-code-search-syntax
documentationhttps://docs.github.com/search-github/github-code-search/understanding-github-code-search-syntax
Sign in https://github.com/login?return_to=https%3A%2F%2Fgithub.com%2FFroussios%2FIntro-To-RxJava%2Fissues%2F2
Sign up https://github.com/signup?ref_cta=Sign+up&ref_loc=header+logged+out&ref_page=%2F%3Cuser-name%3E%2F%3Crepo-name%3E%2Fvoltron%2Fissues_fragments%2Fissue_layout&source=header-repo&source_repo=Froussios%2FIntro-To-RxJava
Reloadhttps://github.com/Froussios/Intro-To-RxJava/issues/2
Reloadhttps://github.com/Froussios/Intro-To-RxJava/issues/2
Reloadhttps://github.com/Froussios/Intro-To-RxJava/issues/2
Froussios https://github.com/Froussios
Intro-To-RxJavahttps://github.com/Froussios/Intro-To-RxJava
Notifications https://github.com/login?return_to=%2FFroussios%2FIntro-To-RxJava
Fork 394 https://github.com/login?return_to=%2FFroussios%2FIntro-To-RxJava
Star 2k https://github.com/login?return_to=%2FFroussios%2FIntro-To-RxJava
Code https://github.com/Froussios/Intro-To-RxJava
Issues 7 https://github.com/Froussios/Intro-To-RxJava/issues
Pull requests 14 https://github.com/Froussios/Intro-To-RxJava/pulls
Actions https://github.com/Froussios/Intro-To-RxJava/actions
Projects https://github.com/Froussios/Intro-To-RxJava/projects
Wiki https://github.com/Froussios/Intro-To-RxJava/wiki
Security and quality 0 https://github.com/Froussios/Intro-To-RxJava/security
Insights https://github.com/Froussios/Intro-To-RxJava/pulse
Code https://github.com/Froussios/Intro-To-RxJava
Issues https://github.com/Froussios/Intro-To-RxJava/issues
Pull requests https://github.com/Froussios/Intro-To-RxJava/pulls
Actions https://github.com/Froussios/Intro-To-RxJava/actions
Projects https://github.com/Froussios/Intro-To-RxJava/projects
Wiki https://github.com/Froussios/Intro-To-RxJava/wiki
Security and quality https://github.com/Froussios/Intro-To-RxJava/security
Insights https://github.com/Froussios/Intro-To-RxJava/pulse
Operator coveragehttps://github.com/Froussios/Intro-To-RxJava/issues/2#top
https://github.com/Froussios
Froussioshttps://github.com/Froussios
on Apr 22, 2015https://github.com/Froussios/Intro-To-RxJava/issues/2#issue-70181303
https://github.com
Termshttps://docs.github.com/site-policy/github-terms/github-terms-of-service
Privacyhttps://docs.github.com/site-policy/privacy-policies/github-privacy-statement
Securityhttps://github.com/security
Statushttps://www.githubstatus.com/
Communityhttps://github.community/
Docshttps://docs.github.com/
Contacthttps://support.github.com?tags=dotcom-footer

Viewport: width=device-width


URLs of crawlers that visited me.