Operator coverage

[Froussios]

Operators covered

• [x] Observable<java.lang.Boolean> all(Func1<? super T,java.lang.Boolean> predicate)
• [x] static <T> Observable<T> amb(java.lang.Iterable<? extends Observable<? extends T>> sources)
• [x] static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2)
• [x] static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3)
• [x] static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4)
• [x] static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5)
• [x] static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6)
• [x] static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7)
• [x] static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8)
• [x] static <T> Observable<T> amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8, Observable<? extends T> o9)
• [x] Observable<T> ambWith(Observable<? extends T> t1)
• [x] Observable<T> asObservable()
• [x] <TClosing> Observable<java.util.List<T>> buffer(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector)
• [x] Observable<java.util.List<T>> buffer(int count)
• [x] Observable<java.util.List<T>> buffer(int count, int skip)
• [x] Observable<java.util.List<T>> buffer(long timespan, long timeshift, java.util.concurrent.TimeUnit unit)
• [x] Observable<java.util.List<T>> buffer(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit)
• [x] Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count)
• [x] Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler)
• [x] Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] <TOpening,TClosing> Observable<java.util.List<T>> buffer(Observable<? extends TOpening> bufferOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> bufferClosingSelector)
• [x] <B> Observable<java.util.List<T>> buffer(Observable<B> boundary)
• [x] <B> Observable<java.util.List<T>> buffer(Observable<B> boundary, int initialCapacity)
• [x] Observable<T> cache()
• [x] Observable<T> cache(int capacity)
• [x] <R> Observable<R> cast(java.lang.Class<R> klass)
• [x] <R> Observable<R> collect(Func0<R> stateFactory, Action2<R,? super T> collector)
• [x] static <T,R> Observable<R> combineLatest(java.util.List<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction)
• [x] static <T1,T2,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Func2<? super T1,? super T2,? extends R> combineFunction)
• [x] static <T1,T2,T3,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1,? super T2,? super T3,? extends R> combineFunction)
• [x] static <T1,T2,T3,T4,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Func4<? super T1,? super T2,? super T3,? super T4,? extends R> combineFunction)
• [x] static <T1,T2,T3,T4,T5,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction)
• [x] static <T1,T2,T3,T4,T5,T6,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction)
• [x] static <T1,T2,T3,T4,T5,T6,T7,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
• [x] static <T1,T2,T3,T4,T5,T6,T7,T8,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
• [x] static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Observable<R> combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Observable<? extends T9> o9, Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
• [x] <R> Observable<R> compose(Observable.Transformer<? super T,? extends R> transformer)
• [x] static <T> Observable<T> concat(Observable<? extends Observable<? extends T>> observables)
• [x] static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2)
• [x] static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3)
• [x] static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4)
• [x] static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5)
• [x] static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6)
• [x] static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7)
• [x] static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8)
• [x] static <T> Observable<T> concat(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9)
• [x] <R> Observable<R> concatMap(Func1<? super T,? extends Observable<? extends R>> func)
• [x] Observable<T> concatWith(Observable<? extends T> t1)
• [x] Observable<java.lang.Boolean> contains(java.lang.Object element)
• [x] Observable<java.lang.Integer> count()
• [x] Observable<java.lang.Long> countLong()
• [x] static <T> Observable<T> create(Observable.OnSubscribe<T> f)
• [x] <U> Observable<T> debounce(Func1<? super T,? extends Observable<U>> debounceSelector)
• [x] Observable<T> debounce(long timeout, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> debounce(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<T> defaultIfEmpty(T defaultValue)
• [x] static <T> Observable<T> defer(Func0<Observable<T>> observableFactory)
• [x] <U,V> Observable<T> delay(Func0<? extends Observable<U>> subscriptionDelay, Func1<? super T,? extends Observable<V>> itemDelay)
• [x] <U> Observable<T> delay(Func1<? super T,? extends Observable<U>> itemDelay)
• [x] Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] <U> Observable<T> delaySubscription(Func0<? extends Observable<U>> subscriptionDelay)
• [x] Observable<T> delaySubscription(long delay, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> delaySubscription(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] <T2> Observable<T2> dematerialize()
• [x] Observable<T> distinct()
• [x] <U> Observable<T> distinct(Func1<? super T,? extends U> keySelector)
• [x] Observable<T> distinctUntilChanged()
• [x] <U> Observable<T> distinctUntilChanged(Func1<? super T,? extends U> keySelector)
• [x] Observable<T> doOnCompleted(Action0 onCompleted)
• [x] Observable<T> doOnEach(Action1<Notification<? super T>> onNotification)
• [x] Observable<T> doOnEach(Observer<? super T> observer)
• [x] Observable<T> doOnError(Action1<java.lang.Throwable> onError)
• [x] Observable<T> doOnNext(Action1<? super T> onNext)
• [x] Observable<T> doOnRequest(Action1<java.lang.Long> onRequest)
• [x] Observable<T> doOnSubscribe(Action0 subscribe)
• [x] Observable<T> doOnTerminate(Action0 onTerminate)
• [x] Observable<T> doOnUnsubscribe(Action0 unsubscribe)
• [x] Observable<T> elementAt(int index)
• [x] Observable<T> elementAtOrDefault(int index, T defaultValue)
• [x] static <T> Observable<T> empty()
• [x] static <T> Observable<T> error(java.lang.Throwable exception)
• [x] Observable<java.lang.Boolean> exists(Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> filter(Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> finallyDo(Action0 action)
• [x] Observable<T> first()
• [x] Observable<T> first(Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> firstOrDefault(T defaultValue)
• [x] Observable<T> firstOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate)
• [x] <R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends R>> func)
• [x] <R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends R>> onNext, Func1<? super java.lang.Throwable,? extends Observable<? extends R>> onError, Func0<? extends Observable<? extends R>> onCompleted)
• [x] <U,R> Observable<R> flatMap(Func1<? super T,? extends Observable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector)
• [x] <R> Observable<R> flatMapIterable(Func1<? super T,? extends java.lang.Iterable<? extends R>> collectionSelector)
• [x] <U,R> Observable<R> flatMapIterable(Func1<? super T,? extends java.lang.Iterable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector)
• [x] void forEach(Action1<? super T> onNext)
• [x] void forEach(Action1<? super T> onNext, Action1<java.lang.Throwable> onError)
• [x] void forEach(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete)
• [x] static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future)
• [x] static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future, long timeout, java.util.concurrent.TimeUnit unit)
• [x] static <T> Observable<T> from(java.util.concurrent.Future<? extends T> future, Scheduler scheduler)
• [x] static <T> Observable<T> from(java.lang.Iterable<? extends T> iterable)
• [x] static <T> Observable<T> from(T[] array)
• [x] <K> Observable<GroupedObservable<K,T>> groupBy(Func1<? super T,? extends K> keySelector)
• [x] <K,R> Observable<GroupedObservable<K,R>> groupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> elementSelector)
• [x] <T2,D1,D2,R> Observable<R> groupJoin(Observable<T2> right, Func1<? super T,? extends Observable<D1>> leftDuration, Func1<? super T2,? extends Observable<D2>> rightDuration, Func2<? super T,? super Observable<T2>,? extends R> resultSelector)
• [x] Observable<T> ignoreElements()
• [x] static Observable<java.lang.Long> interval(long interval, java.util.concurrent.TimeUnit unit)
• [x] static Observable<java.lang.Long> interval(long interval, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<java.lang.Boolean> isEmpty()
• [x] <TRight,TLeftDuration,TRightDuration,R> Observable<R> join(Observable<TRight> right, Func1<T,Observable<TLeftDuration>> leftDurationSelector, Func1<TRight,Observable<TRightDuration>> rightDurationSelector, Func2<T,TRight,R> resultSelector)
• [x] static <T> Observable<T> just(T value)
• [x] static <T> Observable<T> just(T t1, T t2)
• [x] static <T> Observable<T> just(T t1, T t2, T t3)
• [x] static <T> Observable<T> just(T t1, T t2, T t3, T t4)
• [x] static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5)
• [x] static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6)
• [x] static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7)
• [x] static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8)
• [x] static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9)
• [x] static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10)
• [x] Observable<T> last()
• [x] Observable<T> last(Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> lastOrDefault(T defaultValue)
• [x] Observable<T> lastOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate)
• [x] <R> Observable<R> lift(Observable.Operator<? extends R,? super T> lift)
• [x] Observable<T> limit(int num)
• [x] <R> Observable<R> map(Func1<? super T,? extends R> func)
• [x] Observable<Notification<T>> materialize()
• [x] static <T> Observable<T> merge(java.lang.Iterable<? extends Observable<? extends T>> sequences)
• [x] static <T> Observable<T> merge(java.lang.Iterable<? extends Observable<? extends T>> sequences, int maxConcurrent)
• [x] static <T> Observable<T> merge(Observable<? extends Observable<? extends T>> source)
• [x] static <T> Observable<T> merge(Observable<? extends Observable<? extends T>> source, int maxConcurrent)
• [x] static <T> Observable<T> merge(Observable<? extends T>[] sequences)
• [x] static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2)
• [x] static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2,Observable<? extends T> t3)`
• [x] static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4)
• [x] static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5)
• [x] static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6)
• [x] static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7)
• [x] static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8)
• [x] static <T> Observable<T> merge(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends Observable<? extends T>> source)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8)
• [x] static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Observable<? extends T> t2, Observable<? extends T> t3, Observable<? extends T> t4, Observable<? extends T> t5, Observable<? extends T> t6, Observable<? extends T> t7, Observable<? extends T> t8, Observable<? extends T> t9)
• [x] Observable<T> mergeWith(Observable<? extends T> t1)
• [x] Observable<Observable<T>> nest()
• [x] static <T> Observable<T> never()
• [x] Observable<T> observeOn(Scheduler scheduler)
• [x] <R> Observable<R> ofType(java.lang.Class<R> klass)
• [x] Observable<T> onBackpressureBuffer()
• [x] Observable<T> onBackpressureBuffer(long capacity)
• [x] Observable<T> onBackpressureDrop()
• [x] Observable<T> onErrorResumeNext(Func1<java.lang.Throwable,? extends Observable<? extends T>> resumeFunction)
• [x] Observable<T> onErrorResumeNext(Observable<? extends T> resumeSequence)
• [x] Observable<T> onErrorReturn(Func1<java.lang.Throwable,? extends T> resumeFunction)
• [x] Observable<T> onExceptionResumeNext(Observable<? extends T> resumeSequence)
• [x] ConnectableObservable<T> publish()
• [x] <R> Observable<R> publish(Func1<? super Observable<T>,? extends Observable<R>> selector)
• [x] static Observable<java.lang.Integer> range(int start, int count)
• [x] static Observable<java.lang.Integer> range(int start, int count, Scheduler scheduler)
• [x] Observable<T> reduce(Func2<T,T,T> accumulator)
• [x] <R> Observable<R> reduce(R initialValue, Func2<R,? super T,R> accumulator)
• [x] Observable<T> repeat()
• [x] Observable<T> repeat(long count)
• [x] Observable<T> repeat(long count, Scheduler scheduler)
• [x] Observable<T> repeat(Scheduler scheduler)
• [x] Observable<T> repeatWhen(Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler)
• [x] Observable<T> repeatWhen(Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
• [x] ConnectableObservable<T> replay()
• [x] <R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector)
• [x] <R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize)
• [x] <R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit)
• [x] <R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] <R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, Scheduler scheduler)
• [x] <R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, java.util.concurrent.TimeUnit unit)
• [x] <R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] <R> Observable<R> replay(Func1<? super Observable<T>,? extends Observable<R>> selector, Scheduler scheduler)
• [x] ConnectableObservable<T> replay(int bufferSize)
• [x] ConnectableObservable<T> replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit)
• [x] ConnectableObservable<T> replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] ConnectableObservable<T> replay(int bufferSize, Scheduler scheduler)
• [x] ConnectableObservable<T> replay(long time, java.util.concurrent.TimeUnit unit)
• [x] ConnectableObservable<T> replay(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] ConnectableObservable<T> replay(Scheduler scheduler)
• [x] Observable<T> retry()
• [x] Observable<T> retry(Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate)
• [x] Observable<T> retry(long count)
• [x] Observable<T> retryWhen(Func1<? super Observable<? extends java.lang.Throwable>,? extends Observable<?>> notificationHandler)
• [x] Observable<T> retryWhen(Func1<? super Observable<? extends java.lang.Throwable>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
• [x] Observable<T> sample(long period, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> sample(long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] <U> Observable<T> sample(Observable<U> sampler)
• [x] Observable<T> scan(Func2<T,T,T> accumulator)
• [x] <R> Observable<R> scan(R initialValue, Func2<R,? super T,R> accumulator)
• [x] static <T> Observable<java.lang.Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second)
• [x] static <T> Observable<java.lang.Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T,? super T,java.lang.Boolean> equality)
• [x] Observable<T> serialize()
• [x] Observable<T> share()
• [x] Observable<T> single()
• [x] Observable<T> single(Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> singleOrDefault(T defaultValue)
• [x] Observable<T> singleOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> skip(int num)
• [x] Observable<T> skip(long time, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> skip(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<T> skipLast(int count)
• [x] Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] <U> Observable<T> skipUntil(Observable<U> other)
• [x] Observable<T> skipWhile(Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> startWith(java.lang.Iterable<T> values)
• [x] Observable<T> startWith(Observable<T> values)
• [x] Observable<T> startWith(T t1)
• [x] Observable<T> startWith(T t1, T t2)
• [x] Observable<T> startWith(T t1, T t2, T t3)
• [x] Observable<T> startWith(T t1, T t2, T t3, T t4)
• [x] Observable<T> startWith(T t1, T t2, T t3, T t4, T t5)
• [x] Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6)
• [x] Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7)
• [x] Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8)
• [x] Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9)
• [x] Subscription subscribe()
• [x] Subscription subscribe(Action1<? super T> onNext)
• [x] Subscription subscribe(Action1<? super T> onNext, Action1<java.lang.Throwable> onError)
• [x] Subscription subscribe(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete)
• [x] Subscription subscribe(Observer<? super T> observer)
• [x] Subscription subscribe(Subscriber<? super T> subscriber)
• [x] Observable<T> subscribeOn(Scheduler scheduler)
• [x] <R> Observable<R> switchMap(Func1<? super T,? extends Observable<? extends R>> func)
• [x] static <T> Observable<T> switchOnNext(Observable<? extends Observable<? extends T>> sequenceOfSequences)
• [x] Observable<T> take(int num)
• [x] Observable<T> take(long time, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> take(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<T> takeFirst(Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> takeLast(int count)
• [x] Observable<T> takeLast(int count, long time, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> takeLast(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<java.util.List<T>> takeLastBuffer(int count)
• [x] Observable<java.util.List<T>> takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit)
• [x] Observable<java.util.List<T>> takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<java.util.List<T>> takeLastBuffer(long time, java.util.concurrent.TimeUnit unit)
• [x] Observable<java.util.List<T>> takeLastBuffer(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<T> takeUntil(Func1<? super T,java.lang.Boolean> stopPredicate)
• [x] <E> Observable<T> takeUntil(Observable<? extends E> other)
• [x] Observable<T> takeWhile(Func1<? super T,java.lang.Boolean> predicate)
• [x] Observable<T> throttleFirst(long windowDuration, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> throttleFirst(long skipDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<T> throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<T> throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit)
• [x] Observable<T> throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<TimeInterval<T>> timeInterval()
• [x] Observable<TimeInterval<T>> timeInterval(Scheduler scheduler)
• [x] <U,V> Observable<T> timeout(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector)
• [x] <U,V> Observable<T> timeout(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other)
• [x] <V> Observable<T> timeout(Func1<? super T,? extends Observable<V>> timeoutSelector)
• [x] <V> Observable<T> timeout(Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other)
• [x] Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit)
• [x] Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable<? extends T> other)
• [x] Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler)
• [x] Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Scheduler scheduler)
• [x] static Observable<java.lang.Long> timer(long initialDelay, long period, java.util.concurrent.TimeUnit unit)
• [x] static Observable<java.lang.Long> timer(long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] static Observable<java.lang.Long> timer(long delay, java.util.concurrent.TimeUnit unit)
• [x] static Observable<java.lang.Long> timer(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<Timestamped<T>> timestamp()
• [x] Observable<Timestamped<T>> timestamp(Scheduler scheduler)
• [x] BlockingObservable<T> toBlocking()
• [x] Observable<java.util.List<T>> toList()
• [x] <K> Observable<java.util.Map<K,T>> toMap(Func1<? super T,? extends K> keySelector)
• [x] <K,V> Observable<java.util.Map<K,V>> toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector)
• [x] <K,V> Observable<java.util.Map<K,V>> toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,V>> mapFactory)
• [x] <K> Observable<java.util.Map<K,java.util.Collection<T>>> toMultimap(Func1<? super T,? extends K> keySelector)
• [x] <K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector)
• [x] <K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,java.util.Collection<V>>> mapFactory)
• [x] <K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends java.util.Map<K,java.util.Collection<V>>> mapFactory, Func1<? super K,? extends java.util.Collection<V>> collectionFactory)
• [x] Observable<java.util.List<T>> toSortedList()
• [x] Observable<java.util.List<T>> toSortedList(Func2<? super T,? super T,java.lang.Integer> sortFunction)
• [x] Subscription unsafeSubscribe(Subscriber<? super T> subscriber)
• [x] Observable<T> unsubscribeOn(Scheduler scheduler)
• [x] static <T,Resource> Observable<T> using(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> disposeAction)
• [x] <TClosing> Observable<Observable<T>> window(Func0<? extends Observable<? extends TClosing>> closingSelector)
• [x] Observable<Observable<T>> window(int count)
• [x] Observable<Observable<T>> window(int count, int skip)
• [x] Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit)
• [x] Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler)
• [x] Observable<Observable<T>> window(long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit)
• [x] Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, int count)
• [x] Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler)
• [x] Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
• [x] <TOpening,TClosing> Observable<Observable<T>> window(Observable<? extends TOpening> windowOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> closingSelector)
• [x] <U> Observable<Observable<T>> window(Observable<U> boundary)
• [x] static <R> Observable<R> zip(java.lang.Iterable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction)
• [x] static <R> Observable<R> zip(Observable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction)
• [x] static <T1,T2,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Func2<? super T1,? super T2,? extends R> zipFunction)
• [x] static <T1,T2,T3,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
• [x] static <T1,T2,T3,T4,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Func4<? super T1,? super T2,? super T3,? super T4,? extends R> zipFunction)
• [x] static <T1,T2,T3,T4,T5,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction)
• [x] static <T1,T2,T3,T4,T5,T6,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction)
• [x] static <T1,T2,T3,T4,T5,T6,T7,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
• [x] static <T1,T2,T3,T4,T5,T6,T7,T8,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
• [x] static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Observable<R> zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Observable<? extends T4> o4, Observable<? extends T5> o5, Observable<? extends T6> o6, Observable<? extends T7> o7, Observable<? extends T8> o8, Observable<? extends T9> o9, Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
• [x] <T2,R> Observable<R> zipWith(java.lang.Iterable<? extends T2> other, Func2<? super T,? super T2,? extends R> zipFunction)
• [x] `<T2,R> Observable zipWith(Observable<? extends T2> other, Func2<? super T,? super T2,? extends R> zipFunction)``

[Froussios]

Experimental operators

• Observable<T> onBackpressureBlock()
• Observable<T> onBackpressureBlock(int maxQueueLength)
• Observable<T> onBackpressureBuffer(long capacity, Action0 onOverflow)
• Observable<T> switchIfEmpty(Observable<? extends T> alternate)