public class Observable<T>
extends java.lang.Object
implements org.reactivestreams.Publisher<T>
| Modifier and Type | Class and Description |
|---|---|
static interface |
Observable.Operator<Downstream,Upstream>
Interface to map/wrap a downstream subscriber to an upstream subscriber.
|
static interface |
Observable.Transformer<T,R>
Interface to compose observables.
|
| Modifier | Constructor and Description |
|---|---|
protected |
Observable(org.reactivestreams.Publisher<T> onSubscribe) |
| Modifier and Type | Method and Description |
|---|---|
Observable<java.lang.Boolean> |
all(Predicate<? super T> predicate) |
static <T> Observable<T> |
amb(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
amb(org.reactivestreams.Publisher<? extends T>... sources) |
Observable<T> |
ambWith(org.reactivestreams.Publisher<? extends T> other) |
Observable<java.lang.Boolean> |
any(Predicate<? super T> predicate) |
Observable<T> |
asObservable() |
Observable<java.util.List<T>> |
buffer(int count) |
Observable<java.util.List<T>> |
buffer(int count,
int skip) |
<U extends java.util.Collection<? super T>> |
buffer(int count,
int skip,
Supplier<U> bufferSupplier) |
<U extends java.util.Collection<? super T>> |
buffer(int count,
Supplier<U> bufferSupplier) |
Observable<java.util.List<T>> |
buffer(long timespan,
long timeskip,
java.util.concurrent.TimeUnit unit) |
Observable<java.util.List<T>> |
buffer(long timespan,
long timeskip,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
<U extends java.util.Collection<? super T>> |
buffer(long timespan,
long timeskip,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
Supplier<U> bufferSupplier) |
Observable<java.util.List<T>> |
buffer(long timespan,
java.util.concurrent.TimeUnit unit) |
Observable<java.util.List<T>> |
buffer(long timespan,
java.util.concurrent.TimeUnit unit,
int count) |
Observable<java.util.List<T>> |
buffer(long timespan,
java.util.concurrent.TimeUnit unit,
int count,
Scheduler scheduler) |
<U extends java.util.Collection<? super T>> |
buffer(long timespan,
java.util.concurrent.TimeUnit unit,
int count,
Scheduler scheduler,
Supplier<U> bufferSupplier,
boolean restartTimerOnMaxSize) |
Observable<java.util.List<T>> |
buffer(long timespan,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
<TOpening,TClosing> |
buffer(Observable<? extends TOpening> bufferOpenings,
Function<? super TOpening,? extends org.reactivestreams.Publisher<? extends TClosing>> bufferClosingSelector) |
<TOpening,TClosing,U extends java.util.Collection<? super T>> |
buffer(Observable<? extends TOpening> bufferOpenings,
Function<? super TOpening,? extends org.reactivestreams.Publisher<? extends TClosing>> bufferClosingSelector,
Supplier<U> bufferSupplier) |
<B> Observable<java.util.List<T>> |
buffer(org.reactivestreams.Publisher<B> boundary) |
<B> Observable<java.util.List<T>> |
buffer(org.reactivestreams.Publisher<B> boundary,
int initialCapacity) |
<B,U extends java.util.Collection<? super T>> |
buffer(org.reactivestreams.Publisher<B> boundary,
Supplier<U> bufferSupplier) |
<B> Observable<java.util.List<T>> |
buffer(Supplier<? extends org.reactivestreams.Publisher<B>> boundarySupplier) |
<B,U extends java.util.Collection<? super T>> |
buffer(Supplier<? extends org.reactivestreams.Publisher<B>> boundarySupplier,
Supplier<U> bufferSupplier) |
static int |
bufferSize() |
Observable<T> |
cache() |
Observable<T> |
cache(int capacityHint) |
<U> Observable<U> |
cast(java.lang.Class<U> clazz) |
<U> Observable<U> |
collect(Supplier<? extends U> initialValueSupplier,
BiConsumer<? super U,? super T> collector) |
<U> Observable<U> |
collectInto(U initialValue,
BiConsumer<? super U,? super T> collector) |
static <T,R> Observable<R> |
combineLatest(Function<? super java.lang.Object[],? extends R> combiner,
boolean delayError,
int bufferSize,
org.reactivestreams.Publisher<? extends T>... sources) |
static <T,R> Observable<R> |
combineLatest(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super java.lang.Object[],? extends R> combiner) |
static <T,R> Observable<R> |
combineLatest(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super java.lang.Object[],? extends R> combiner,
boolean delayError) |
static <T,R> Observable<R> |
combineLatest(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super java.lang.Object[],? extends R> combiner,
boolean delayError,
int bufferSize) |
static <T,R> Observable<R> |
combineLatest(org.reactivestreams.Publisher<? extends T>[] sources,
Function<? super java.lang.Object[],? extends R> combiner) |
static <T,R> Observable<R> |
combineLatest(org.reactivestreams.Publisher<? extends T>[] sources,
Function<? super java.lang.Object[],? extends R> combiner,
boolean delayError) |
static <T,R> Observable<R> |
combineLatest(org.reactivestreams.Publisher<? extends T>[] sources,
Function<? super java.lang.Object[],? extends R> combiner,
boolean delayError,
int bufferSize) |
static <T1,T2,R> Observable<R> |
combineLatest(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
BiFunction<? super T1,? super T2,? extends R> combiner) |
static <T1,T2,T3,R> |
combineLatest(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
Function3<? super T1,? super T2,? super T3,? extends R> combiner) |
static <T1,T2,T3,T4,R> |
combineLatest(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> combiner) |
static <T1,T2,T3,T4,T5,R> |
combineLatest(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combiner) |
static <T1,T2,T3,T4,T5,T6,R> |
combineLatest(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
org.reactivestreams.Publisher<? extends T6> p6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combiner) |
static <T1,T2,T3,T4,T5,T6,T7,R> |
combineLatest(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
org.reactivestreams.Publisher<? extends T6> p6,
org.reactivestreams.Publisher<? extends T7> p7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner) |
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
combineLatest(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
org.reactivestreams.Publisher<? extends T6> p6,
org.reactivestreams.Publisher<? extends T7> p7,
org.reactivestreams.Publisher<? extends T8> p8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner) |
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
combineLatest(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
org.reactivestreams.Publisher<? extends T6> p6,
org.reactivestreams.Publisher<? extends T7> p7,
org.reactivestreams.Publisher<? extends T8> p8,
org.reactivestreams.Publisher<? extends T9> p9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner) |
<R> Observable<R> |
compose(Observable.Transformer<T,R> composer) |
static <T> Observable<T> |
concat(int prefetch,
java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
concat(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources,
int bufferSize) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3,
org.reactivestreams.Publisher<? extends T> p4) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3,
org.reactivestreams.Publisher<? extends T> p4,
org.reactivestreams.Publisher<? extends T> p5) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3,
org.reactivestreams.Publisher<? extends T> p4,
org.reactivestreams.Publisher<? extends T> p5,
org.reactivestreams.Publisher<? extends T> p6) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3,
org.reactivestreams.Publisher<? extends T> p4,
org.reactivestreams.Publisher<? extends T> p5,
org.reactivestreams.Publisher<? extends T> p6,
org.reactivestreams.Publisher<? extends T> p7) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3,
org.reactivestreams.Publisher<? extends T> p4,
org.reactivestreams.Publisher<? extends T> p5,
org.reactivestreams.Publisher<? extends T> p6,
org.reactivestreams.Publisher<? extends T> p7,
org.reactivestreams.Publisher<? extends T> p8) |
static <T> Observable<T> |
concat(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3,
org.reactivestreams.Publisher<? extends T> p4,
org.reactivestreams.Publisher<? extends T> p5,
org.reactivestreams.Publisher<? extends T> p6,
org.reactivestreams.Publisher<? extends T> p7,
org.reactivestreams.Publisher<? extends T> p8,
org.reactivestreams.Publisher<? extends T> p9) |
static <T> Observable<T> |
concatArray(int prefetch,
org.reactivestreams.Publisher<? extends T>... sources) |
static <T> Observable<T> |
concatArray(org.reactivestreams.Publisher<? extends T>... sources)
Concatenates a variable number of Observable sources.
|
<R> Observable<R> |
concatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper) |
<R> Observable<R> |
concatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch) |
<U> Observable<U> |
concatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper) |
<U> Observable<U> |
concatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper,
int prefetch) |
Observable<T> |
concatWith(org.reactivestreams.Publisher<? extends T> other) |
Observable<java.lang.Boolean> |
contains(java.lang.Object o) |
Observable<java.lang.Long> |
count() |
static <T> Observable<T> |
create(org.reactivestreams.Publisher<T> onSubscribe) |
<U> Observable<T> |
debounce(Function<? super T,? extends org.reactivestreams.Publisher<U>> debounceSelector) |
Observable<T> |
debounce(long timeout,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
debounce(long timeout,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
defaultIfEmpty(T value) |
static <T> Observable<T> |
defer(Supplier<? extends org.reactivestreams.Publisher<? extends T>> supplier) |
<U> Observable<T> |
delay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay) |
Observable<T> |
delay(long delay,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
delay(long delay,
java.util.concurrent.TimeUnit unit,
boolean delayError) |
Observable<T> |
delay(long delay,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
delay(long delay,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
boolean delayError) |
<U,V> Observable<T> |
delay(Supplier<? extends org.reactivestreams.Publisher<U>> delaySupplier,
Function<? super T,? extends org.reactivestreams.Publisher<V>> itemDelay) |
Observable<T> |
delaySubscription(long delay,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
delaySubscription(long delay,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
<U> Observable<T> |
delaySubscription(org.reactivestreams.Publisher<U> other)
Returns an Observable that delays the subscription to this Observable
until the other Observable emits an element or completes normally.
|
<U> Observable<T> |
delaySubscription(Supplier<? extends org.reactivestreams.Publisher<U>> delaySupplier) |
<T2> Observable<T2> |
dematerialize() |
Observable<T> |
distinct() |
<K> Observable<T> |
distinct(Function<? super T,K> keySelector) |
<K> Observable<T> |
distinct(Function<? super T,K> keySelector,
Supplier<? extends java.util.Collection<? super K>> collectionSupplier) |
Observable<T> |
distinctUntilChanged() |
<K> Observable<T> |
distinctUntilChanged(Function<? super T,K> keySelector) |
Observable<T> |
doOnCancel(java.lang.Runnable onCancel) |
Observable<T> |
doOnComplete(java.lang.Runnable onComplete) |
Observable<T> |
doOnEach(Consumer<? super Try<Optional<T>>> consumer) |
Observable<T> |
doOnEach(org.reactivestreams.Subscriber<? super T> observer) |
Observable<T> |
doOnError(Consumer<? super java.lang.Throwable> onError) |
Observable<T> |
doOnLifecycle(Consumer<? super org.reactivestreams.Subscription> onSubscribe,
LongConsumer onRequest,
java.lang.Runnable onCancel) |
Observable<T> |
doOnNext(Consumer<? super T> onNext) |
Observable<T> |
doOnRequest(LongConsumer onRequest) |
Observable<T> |
doOnSubscribe(Consumer<? super org.reactivestreams.Subscription> onSubscribe) |
Observable<T> |
doOnTerminate(java.lang.Runnable onTerminate) |
Observable<T> |
elementAt(long index) |
Observable<T> |
elementAt(long index,
T defaultValue) |
static <T> Observable<T> |
empty() |
Observable<T> |
endWith(java.lang.Iterable<? extends T> values) |
Observable<T> |
endWith(org.reactivestreams.Publisher<? extends T> other) |
Observable<T> |
endWith(T value) |
Observable<T> |
endWithArray(T... values) |
static <T> Observable<T> |
error(Supplier<? extends java.lang.Throwable> errorSupplier) |
static <T> Observable<T> |
error(java.lang.Throwable e) |
Observable<T> |
filter(Predicate<? super T> predicate) |
Observable<T> |
finallyDo(java.lang.Runnable onFinally) |
Observable<T> |
first() |
Observable<T> |
first(T defaultValue) |
<R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper) |
<R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayErrors) |
<R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency) |
<R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize) |
<R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> onNextMapper,
Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends R>> onErrorMapper,
Supplier<? extends org.reactivestreams.Publisher<? extends R>> onCompleteSupplier) |
<R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> onNextMapper,
Function<java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends R>> onErrorMapper,
Supplier<? extends org.reactivestreams.Publisher<? extends R>> onCompleteSupplier,
int maxConcurrency) |
<R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int maxConcurrency) |
<U,R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> resultSelector) |
<U,R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayError) |
<U,R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayError,
int maxConcurrency) |
<U,R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayError,
int maxConcurrency,
int bufferSize) |
<U,R> Observable<R> |
flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
int maxConcurrency) |
<U> Observable<U> |
flatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper) |
<U,V> Observable<V> |
flatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper,
BiFunction<? super T,? super U,? extends V> resultSelector) |
<U> Observable<U> |
flatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper,
int bufferSize) |
Disposable |
forEach(Consumer<? super T> onNext) |
Disposable |
forEachWhile(Predicate<? super T> onNext) |
Disposable |
forEachWhile(Predicate<? super T> onNext,
Consumer<? super java.lang.Throwable> onError) |
Disposable |
forEachWhile(Predicate<? super T> onNext,
Consumer<? super java.lang.Throwable> onError,
java.lang.Runnable onComplete) |
static <T> Observable<T> |
fromArray(T... values) |
static <T> Observable<T> |
fromCallable(java.util.concurrent.Callable<? extends T> supplier) |
static <T> Observable<T> |
fromFuture(java.util.concurrent.Future<? extends T> future) |
static <T> Observable<T> |
fromFuture(java.util.concurrent.Future<? extends T> future,
long timeout,
java.util.concurrent.TimeUnit unit) |
static <T> Observable<T> |
fromFuture(java.util.concurrent.Future<? extends T> future,
long timeout,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
static <T> Observable<T> |
fromFuture(java.util.concurrent.Future<? extends T> future,
Scheduler scheduler) |
static <T> Observable<T> |
fromIterable(java.lang.Iterable<? extends T> source) |
static <T> Observable<T> |
fromPublisher(org.reactivestreams.Publisher<? extends T> publisher) |
static <T> Observable<T> |
generate(Consumer<org.reactivestreams.Subscriber<T>> generator) |
static <T,S> Observable<T> |
generate(Supplier<S> initialState,
BiConsumer<S,org.reactivestreams.Subscriber<T>> generator) |
static <T,S> Observable<T> |
generate(Supplier<S> initialState,
BiConsumer<S,org.reactivestreams.Subscriber<T>> generator,
Consumer<? super S> disposeState) |
static <T,S> Observable<T> |
generate(Supplier<S> initialState,
BiFunction<S,org.reactivestreams.Subscriber<T>,S> generator) |
static <T,S> Observable<T> |
generate(Supplier<S> initialState,
BiFunction<S,org.reactivestreams.Subscriber<T>,S> generator,
Consumer<? super S> disposeState) |
<K> Observable<GroupedObservable<K,T>> |
groupBy(Function<? super T,? extends K> keySelector) |
<K> Observable<GroupedObservable<K,T>> |
groupBy(Function<? super T,? extends K> keySelector,
boolean delayError) |
<K,V> Observable<GroupedObservable<K,V>> |
groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector) |
<K,V> Observable<GroupedObservable<K,V>> |
groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError) |
<K,V> Observable<GroupedObservable<K,V>> |
groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize) |
Observable<T> |
ignoreElements() |
static Observable<java.lang.Long> |
interval(long initialDelay,
long period,
java.util.concurrent.TimeUnit unit) |
static Observable<java.lang.Long> |
interval(long initialDelay,
long period,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
static Observable<java.lang.Long> |
interval(long period,
java.util.concurrent.TimeUnit unit) |
static Observable<java.lang.Long> |
interval(long period,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
static Observable<java.lang.Long> |
intervalRange(long start,
long count,
long initialDelay,
long period,
java.util.concurrent.TimeUnit unit) |
static Observable<java.lang.Long> |
intervalRange(long start,
long count,
long initialDelay,
long period,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<java.lang.Boolean> |
isEmpty() |
static <T> Observable<T> |
just(T value) |
static <T> Observable<T> |
just(T v1,
T v2) |
static <T> Observable<T> |
just(T v1,
T v2,
T v3) |
static <T> Observable<T> |
just(T v1,
T v2,
T v3,
T v4) |
static <T> Observable<T> |
just(T v1,
T v2,
T v3,
T v4,
T v5) |
static <T> Observable<T> |
just(T v1,
T v2,
T v3,
T v4,
T v5,
T v6) |
static <T> Observable<T> |
just(T v1,
T v2,
T v3,
T v4,
T v5,
T v6,
T v7) |
static <T> Observable<T> |
just(T v1,
T v2,
T v3,
T v4,
T v5,
T v6,
T v7,
T v8) |
static <T> Observable<T> |
just(T v1,
T v2,
T v3,
T v4,
T v5,
T v6,
T v7,
T v8,
T v9) |
Observable<T> |
last() |
Observable<T> |
last(T defaultValue) |
<R> Observable<R> |
lift(Observable.Operator<? extends R,? super T> lifter) |
<R> Observable<R> |
map(Function<? super T,? extends R> mapper) |
Observable<Try<Optional<T>>> |
materialize() |
static <T> Observable<T> |
merge(int maxConcurrency,
int bufferSize,
java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
merge(int maxConcurrency,
int bufferSize,
org.reactivestreams.Publisher<? extends T>... sources) |
static <T> Observable<T> |
merge(int maxConcurrency,
org.reactivestreams.Publisher<? extends T>... sources) |
static <T> Observable<T> |
merge(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
merge(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
int maxConcurrency) |
static <T> Observable<T> |
merge(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
merge(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources,
int maxConcurrency) |
static <T> Observable<T> |
merge(org.reactivestreams.Publisher<? extends T>... sources) |
static <T> Observable<T> |
merge(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2) |
static <T> Observable<T> |
merge(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3) |
static <T> Observable<T> |
merge(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3,
org.reactivestreams.Publisher<? extends T> p4) |
static <T> Observable<T> |
mergeDelayError(boolean delayErrors,
java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
mergeDelayError(int maxConcurrency,
int bufferSize,
java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
mergeDelayError(int maxConcurrency,
int bufferSize,
org.reactivestreams.Publisher<? extends T>... sources) |
static <T> Observable<T> |
mergeDelayError(int maxConcurrency,
java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
mergeDelayError(int maxConcurrency,
org.reactivestreams.Publisher<? extends T>... sources) |
static <T> Observable<T> |
mergeDelayError(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
mergeDelayError(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources,
int maxConcurrency) |
static <T> Observable<T> |
mergeDelayError(org.reactivestreams.Publisher<? extends T>... sources) |
static <T> Observable<T> |
mergeDelayError(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2) |
static <T> Observable<T> |
mergeDelayError(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3) |
static <T> Observable<T> |
mergeDelayError(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
org.reactivestreams.Publisher<? extends T> p3,
org.reactivestreams.Publisher<? extends T> p4) |
Observable<T> |
mergeWith(org.reactivestreams.Publisher<? extends T> other) |
Observable<Observable<T>> |
nest()
Deprecated.
|
static <T> Observable<T> |
never() |
Observable<T> |
observeOn(Scheduler scheduler) |
Observable<T> |
observeOn(Scheduler scheduler,
boolean delayError) |
Observable<T> |
observeOn(Scheduler scheduler,
boolean delayError,
int bufferSize) |
<U> Observable<U> |
ofType(java.lang.Class<U> clazz) |
Observable<T> |
onBackpressureBuffer() |
Observable<T> |
onBackpressureBuffer(boolean delayError) |
Observable<T> |
onBackpressureBuffer(int bufferSize) |
Observable<T> |
onBackpressureBuffer(int bufferSize,
boolean delayError) |
Observable<T> |
onBackpressureBuffer(int bufferSize,
boolean delayError,
boolean unbounded) |
Observable<T> |
onBackpressureBuffer(int bufferSize,
boolean delayError,
boolean unbounded,
java.lang.Runnable onOverflow) |
Observable<T> |
onBackpressureBuffer(int bufferSize,
java.lang.Runnable onOverflow) |
Observable<T> |
onBackpressureDrop() |
Observable<T> |
onBackpressureDrop(Consumer<? super T> onDrop) |
Observable<T> |
onBackpressureLatest() |
Observable<T> |
onErrorResumeNext(Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends T>> resumeFunction) |
Observable<T> |
onErrorResumeNext(org.reactivestreams.Publisher<? extends T> next) |
Observable<T> |
onErrorReturn(Function<? super java.lang.Throwable,? extends T> valueSupplier) |
Observable<T> |
onErrorReturnValue(T value) |
Observable<T> |
onExceptionResumeNext(org.reactivestreams.Publisher<? extends T> next) |
ConnectableObservable<T> |
publish() |
<R> Observable<R> |
publish(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector) |
<R> Observable<R> |
publish(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize) |
ConnectableObservable<T> |
publish(int bufferSize) |
static Observable<java.lang.Integer> |
range(int start,
int count) |
Observable<T> |
reduce(BiFunction<T,T,T> reducer) |
<R> Observable<R> |
reduce(R seed,
BiFunction<R,? super T,R> reducer) |
<R> Observable<R> |
reduceWith(Supplier<R> seedSupplier,
BiFunction<R,? super T,R> reducer) |
Observable<T> |
repeat() |
Observable<T> |
repeat(long times) |
Observable<T> |
repeatUntil(BooleanSupplier stop) |
Observable<T> |
repeatWhen(Function<? super Observable<java.lang.Object>,? extends org.reactivestreams.Publisher<?>> handler) |
ConnectableObservable<T> |
replay() |
<R> Observable<R> |
replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector) |
<R> Observable<R> |
replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize) |
<R> Observable<R> |
replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize,
long time,
java.util.concurrent.TimeUnit unit) |
<R> Observable<R> |
replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize,
long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
<R> Observable<R> |
replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize,
Scheduler scheduler) |
<R> Observable<R> |
replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector,
long time,
java.util.concurrent.TimeUnit unit) |
<R> Observable<R> |
replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector,
long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
<R> Observable<R> |
replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector,
Scheduler scheduler) |
ConnectableObservable<T> |
replay(int bufferSize) |
ConnectableObservable<T> |
replay(int bufferSize,
long time,
java.util.concurrent.TimeUnit unit) |
ConnectableObservable<T> |
replay(int bufferSize,
long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
ConnectableObservable<T> |
replay(int bufferSize,
Scheduler scheduler) |
ConnectableObservable<T> |
replay(long time,
java.util.concurrent.TimeUnit unit) |
ConnectableObservable<T> |
replay(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
ConnectableObservable<T> |
replay(Scheduler scheduler) |
Observable<T> |
retry() |
Observable<T> |
retry(BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate) |
Observable<T> |
retry(long times) |
Observable<T> |
retry(long times,
Predicate<? super java.lang.Throwable> predicate) |
Observable<T> |
retry(Predicate<? super java.lang.Throwable> predicate) |
Observable<T> |
retryUntil(BooleanSupplier stop) |
Observable<T> |
retryWhen(Function<? super Observable<? extends java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> handler) |
void |
safeSubscribe(org.reactivestreams.Subscriber<? super T> s) |
Observable<T> |
sample(long period,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
sample(long period,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
<U> Observable<T> |
sample(org.reactivestreams.Publisher<U> sampler) |
Observable<T> |
scan(BiFunction<T,T,T> accumulator) |
<R> Observable<R> |
scan(R seed,
BiFunction<R,? super T,R> accumulator) |
<R> Observable<R> |
scanWith(Supplier<R> seedSupplier,
BiFunction<R,? super T,R> accumulator) |
static <T> Observable<java.lang.Boolean> |
sequenceEqual(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2) |
static <T> Observable<java.lang.Boolean> |
sequenceEqual(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
BiPredicate<? super T,? super T> isEqual) |
static <T> Observable<java.lang.Boolean> |
sequenceEqual(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
BiPredicate<? super T,? super T> isEqual,
int bufferSize) |
static <T> Observable<java.lang.Boolean> |
sequenceEqual(org.reactivestreams.Publisher<? extends T> p1,
org.reactivestreams.Publisher<? extends T> p2,
int bufferSize) |
Observable<T> |
serialize() |
Observable<T> |
share() |
Observable<T> |
single() |
Observable<T> |
single(T defaultValue) |
Observable<T> |
skip(long n) |
Observable<T> |
skip(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
skipLast(int n) |
Observable<T> |
skipLast(long time,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
skipLast(long time,
java.util.concurrent.TimeUnit unit,
boolean delayError) |
Observable<T> |
skipLast(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
skipLast(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
boolean delayError) |
Observable<T> |
skipLast(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
boolean delayError,
int bufferSize) |
<U> Observable<T> |
skipUntil(org.reactivestreams.Publisher<U> other) |
Observable<T> |
skipWhile(Predicate<? super T> predicate) |
Observable<T> |
startWith(java.lang.Iterable<? extends T> values) |
Observable<T> |
startWith(org.reactivestreams.Publisher<? extends T> other) |
Observable<T> |
startWith(T value) |
Observable<T> |
startWithArray(T... values) |
Disposable |
subscribe() |
Disposable |
subscribe(Consumer<? super T> onNext) |
Disposable |
subscribe(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError) |
Disposable |
subscribe(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError,
java.lang.Runnable onComplete) |
Disposable |
subscribe(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError,
java.lang.Runnable onComplete,
Consumer<? super org.reactivestreams.Subscription> onSubscribe) |
void |
subscribe(org.reactivestreams.Subscriber<? super T> s) |
Observable<T> |
subscribeOn(Scheduler scheduler) |
Observable<T> |
subscribeOn(Scheduler scheduler,
boolean requestOn) |
Observable<T> |
switchIfEmpty(org.reactivestreams.Publisher<? extends T> other) |
<R> Observable<R> |
switchMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper) |
<R> Observable<R> |
switchMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int bufferSize) |
static <T> Observable<T> |
switchOnNext(int bufferSize,
org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources) |
static <T> Observable<T> |
switchOnNext(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources) |
Observable<T> |
take(long n) |
Observable<T> |
take(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
takeFirst(Predicate<? super T> predicate) |
Observable<T> |
takeLast(int n) |
Observable<T> |
takeLast(long count,
long time,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
takeLast(long count,
long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
takeLast(long count,
long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
boolean delayError,
int bufferSize) |
Observable<T> |
takeLast(long time,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
takeLast(long time,
java.util.concurrent.TimeUnit unit,
boolean delayError) |
Observable<T> |
takeLast(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
takeLast(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
boolean delayError) |
Observable<T> |
takeLast(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
boolean delayError,
int bufferSize) |
Observable<java.util.List<T>> |
takeLastBuffer(int count) |
Observable<java.util.List<T>> |
takeLastBuffer(int count,
long time,
java.util.concurrent.TimeUnit unit) |
Observable<java.util.List<T>> |
takeLastBuffer(int count,
long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<java.util.List<T>> |
takeLastBuffer(long time,
java.util.concurrent.TimeUnit unit) |
Observable<java.util.List<T>> |
takeLastBuffer(long time,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
takeUntil(Predicate<? super T> predicate) |
<U> Observable<T> |
takeUntil(org.reactivestreams.Publisher<U> other) |
Observable<T> |
takeWhile(Predicate<? super T> predicate) |
Observable<T> |
throttleFirst(long windowDuration,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
throttleFirst(long skipDuration,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
throttleLast(long intervalDuration,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
throttleLast(long intervalDuration,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<T> |
throttleWithTimeout(long timeout,
java.util.concurrent.TimeUnit unit) |
Observable<T> |
throttleWithTimeout(long timeout,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<Timed<T>> |
timeInterval() |
Observable<Timed<T>> |
timeInterval(Scheduler scheduler) |
Observable<Timed<T>> |
timeInterval(java.util.concurrent.TimeUnit unit) |
Observable<Timed<T>> |
timeInterval(java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
<V> Observable<T> |
timeout(Function<? super T,? extends org.reactivestreams.Publisher<V>> timeoutSelector) |
<V> Observable<T> |
timeout(Function<? super T,? extends org.reactivestreams.Publisher<V>> timeoutSelector,
Observable<? extends T> other) |
Observable<T> |
timeout(long timeout,
java.util.concurrent.TimeUnit timeUnit) |
Observable<T> |
timeout(long timeout,
java.util.concurrent.TimeUnit timeUnit,
Observable<? extends T> other) |
Observable<T> |
timeout(long timeout,
java.util.concurrent.TimeUnit timeUnit,
Observable<? extends T> other,
Scheduler scheduler) |
Observable<T> |
timeout(long timeout,
java.util.concurrent.TimeUnit timeUnit,
Scheduler scheduler) |
<U,V> Observable<T> |
timeout(Supplier<? extends org.reactivestreams.Publisher<U>> firstTimeoutSelector,
Function<? super T,? extends org.reactivestreams.Publisher<V>> timeoutSelector) |
<U,V> Observable<T> |
timeout(Supplier<? extends org.reactivestreams.Publisher<U>> firstTimeoutSelector,
Function<? super T,? extends org.reactivestreams.Publisher<V>> timeoutSelector,
org.reactivestreams.Publisher<? extends T> other) |
static Observable<java.lang.Long> |
timer(long delay,
java.util.concurrent.TimeUnit unit) |
static Observable<java.lang.Long> |
timer(long delay,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<Timed<T>> |
timestamp() |
Observable<Timed<T>> |
timestamp(Scheduler scheduler) |
Observable<Timed<T>> |
timestamp(java.util.concurrent.TimeUnit unit) |
Observable<Timed<T>> |
timestamp(java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
<R> R |
to(Function<? super Observable<T>,R> converter) |
BlockingObservable<T> |
toBlocking() |
Observable<java.util.List<T>> |
toList() |
Observable<java.util.List<T>> |
toList(int capacityHint) |
<U extends java.util.Collection<? super T>> |
toList(Supplier<U> collectionSupplier) |
<K> Observable<java.util.Map<K,T>> |
toMap(Function<? super T,? extends K> keySelector) |
<K,V> Observable<java.util.Map<K,V>> |
toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector) |
<K,V> Observable<java.util.Map<K,V>> |
toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Supplier<? extends java.util.Map<K,V>> mapSupplier) |
<K> Observable<java.util.Map<K,java.util.Collection<T>>> |
toMultimap(Function<? super T,? extends K> keySelector) |
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> |
toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector) |
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> |
toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Supplier<? extends java.util.Map<K,java.util.Collection<V>>> mapSupplier,
Function<? super K,? extends java.util.Collection<? super V>> collectionFactory) |
<K,V> Observable<java.util.Map<K,java.util.Collection<V>>> |
toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Supplier<java.util.Map<K,java.util.Collection<V>>> mapSupplier) |
NbpObservable<T> |
toNbpObservable() |
Single<T> |
toSingle() |
Observable<java.util.List<T>> |
toSortedList() |
Observable<java.util.List<T>> |
toSortedList(java.util.Comparator<? super T> comparator) |
Observable<java.util.List<T>> |
toSortedList(java.util.Comparator<? super T> comparator,
int capacityHint) |
Observable<java.util.List<T>> |
toSortedList(int capacityHint) |
void |
unsafeSubscribe(org.reactivestreams.Subscriber<? super T> s) |
Observable<T> |
unsubscribeOn(Scheduler scheduler) |
static <T,D> Observable<T> |
using(Supplier<? extends D> resourceSupplier,
Function<? super D,? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier,
Consumer<? super D> disposer) |
static <T,D> Observable<T> |
using(Supplier<? extends D> resourceSupplier,
Function<? super D,? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier,
Consumer<? super D> disposer,
boolean eager) |
Observable<Observable<T>> |
window(long count) |
Observable<Observable<T>> |
window(long count,
long skip) |
Observable<Observable<T>> |
window(long count,
long skip,
int bufferSize) |
Observable<Observable<T>> |
window(long timespan,
long timeskip,
java.util.concurrent.TimeUnit unit) |
Observable<Observable<T>> |
window(long timespan,
long timeskip,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<Observable<T>> |
window(long timespan,
long timeskip,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
int bufferSize) |
Observable<Observable<T>> |
window(long timespan,
java.util.concurrent.TimeUnit unit) |
Observable<Observable<T>> |
window(long timespan,
java.util.concurrent.TimeUnit unit,
long count) |
Observable<Observable<T>> |
window(long timespan,
java.util.concurrent.TimeUnit unit,
long count,
boolean restart) |
Observable<Observable<T>> |
window(long timespan,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Observable<Observable<T>> |
window(long timespan,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
long count) |
Observable<Observable<T>> |
window(long timespan,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
long count,
boolean restart) |
Observable<Observable<T>> |
window(long timespan,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
long count,
boolean restart,
int bufferSize) |
<B> Observable<Observable<T>> |
window(org.reactivestreams.Publisher<B> boundary) |
<B> Observable<Observable<T>> |
window(org.reactivestreams.Publisher<B> boundary,
int bufferSize) |
<U,V> Observable<Observable<T>> |
window(org.reactivestreams.Publisher<U> windowOpen,
Function<? super U,? extends org.reactivestreams.Publisher<V>> windowClose) |
<U,V> Observable<Observable<T>> |
window(org.reactivestreams.Publisher<U> windowOpen,
Function<? super U,? extends org.reactivestreams.Publisher<V>> windowClose,
int bufferSize) |
<B> Observable<Observable<T>> |
window(Supplier<? extends org.reactivestreams.Publisher<B>> boundary) |
<B> Observable<Observable<T>> |
window(Supplier<? extends org.reactivestreams.Publisher<B>> boundary,
int bufferSize) |
<U,R> Observable<R> |
withLatestFrom(org.reactivestreams.Publisher<? extends U> other,
BiFunction<? super T,? super U,? extends R> combiner) |
static <T,R> Observable<R> |
zip(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super java.lang.Object[],? extends R> zipper) |
static <T,R> Observable<R> |
zip(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super java.lang.Object[],? extends R> zipper) |
static <T1,T2,R> Observable<R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
BiFunction<? super T1,? super T2,? extends R> zipper) |
static <T1,T2,R> Observable<R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
BiFunction<? super T1,? super T2,? extends R> zipper,
boolean delayError) |
static <T1,T2,R> Observable<R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
BiFunction<? super T1,? super T2,? extends R> zipper,
boolean delayError,
int bufferSize) |
static <T1,T2,T3,R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
Function3<? super T1,? super T2,? super T3,? extends R> zipper) |
static <T1,T2,T3,T4,R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> zipper) |
static <T1,T2,T3,T4,T5,R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper) |
static <T1,T2,T3,T4,T5,T6,R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
org.reactivestreams.Publisher<? extends T6> p6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper) |
static <T1,T2,T3,T4,T5,T6,T7,R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
org.reactivestreams.Publisher<? extends T6> p6,
org.reactivestreams.Publisher<? extends T7> p7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper) |
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
org.reactivestreams.Publisher<? extends T6> p6,
org.reactivestreams.Publisher<? extends T7> p7,
org.reactivestreams.Publisher<? extends T8> p8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper) |
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
zip(org.reactivestreams.Publisher<? extends T1> p1,
org.reactivestreams.Publisher<? extends T2> p2,
org.reactivestreams.Publisher<? extends T3> p3,
org.reactivestreams.Publisher<? extends T4> p4,
org.reactivestreams.Publisher<? extends T5> p5,
org.reactivestreams.Publisher<? extends T6> p6,
org.reactivestreams.Publisher<? extends T7> p7,
org.reactivestreams.Publisher<? extends T8> p8,
org.reactivestreams.Publisher<? extends T9> p9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper) |
static <T,R> Observable<R> |
zipArray(Function<? super java.lang.Object[],? extends R> zipper,
boolean delayError,
int bufferSize,
org.reactivestreams.Publisher<? extends T>... sources) |
static <T,R> Observable<R> |
zipIterable(Function<? super java.lang.Object[],? extends R> zipper,
boolean delayError,
int bufferSize,
java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources) |
<U,R> Observable<R> |
zipWith(java.lang.Iterable<U> other,
BiFunction<? super T,? super U,? extends R> zipper) |
<U,R> Observable<R> |
zipWith(org.reactivestreams.Publisher<? extends U> other,
BiFunction<? super T,? super U,? extends R> zipper) |
<U,R> Observable<R> |
zipWith(org.reactivestreams.Publisher<? extends U> other,
BiFunction<? super T,? super U,? extends R> zipper,
boolean delayError) |
<U,R> Observable<R> |
zipWith(org.reactivestreams.Publisher<? extends U> other,
BiFunction<? super T,? super U,? extends R> zipper,
boolean delayError,
int bufferSize) |
protected Observable(org.reactivestreams.Publisher<T> onSubscribe)
public static <T> Observable<T> amb(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> amb(org.reactivestreams.Publisher<? extends T>... sources)
public static int bufferSize()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> combineLatest(Function<? super java.lang.Object[],? extends R> combiner, boolean delayError, int bufferSize, org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> combineLatest(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources, Function<? super java.lang.Object[],? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> combineLatest(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources, Function<? super java.lang.Object[],? extends R> combiner, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> combineLatest(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources, Function<? super java.lang.Object[],? extends R> combiner, boolean delayError, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T>[] sources, Function<? super java.lang.Object[],? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T>[] sources, Function<? super java.lang.Object[],? extends R> combiner, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T>[] sources, Function<? super java.lang.Object[],? extends R> combiner, boolean delayError, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, BiFunction<? super T1,? super T2,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, Function3<? super T1,? super T2,? super T3,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, Function4<? super T1,? super T2,? super T3,? super T4,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,T6,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, org.reactivestreams.Publisher<? extends T6> p6, Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,T6,T7,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, org.reactivestreams.Publisher<? extends T6> p6, org.reactivestreams.Publisher<? extends T7> p7, Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,T6,T7,T8,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, org.reactivestreams.Publisher<? extends T6> p6, org.reactivestreams.Publisher<? extends T7> p7, org.reactivestreams.Publisher<? extends T8> p8, Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Observable<R> combineLatest(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, org.reactivestreams.Publisher<? extends T6> p6, org.reactivestreams.Publisher<? extends T7> p7, org.reactivestreams.Publisher<? extends T8> p8, org.reactivestreams.Publisher<? extends T9> p9, Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(int prefetch, java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> concat(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> concat(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3, org.reactivestreams.Publisher<? extends T> p4)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3, org.reactivestreams.Publisher<? extends T> p4, org.reactivestreams.Publisher<? extends T> p5)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3, org.reactivestreams.Publisher<? extends T> p4, org.reactivestreams.Publisher<? extends T> p5, org.reactivestreams.Publisher<? extends T> p6)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3, org.reactivestreams.Publisher<? extends T> p4, org.reactivestreams.Publisher<? extends T> p5, org.reactivestreams.Publisher<? extends T> p6, org.reactivestreams.Publisher<? extends T> p7)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3, org.reactivestreams.Publisher<? extends T> p4, org.reactivestreams.Publisher<? extends T> p5, org.reactivestreams.Publisher<? extends T> p6, org.reactivestreams.Publisher<? extends T> p7, org.reactivestreams.Publisher<? extends T> p8)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concat(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3, org.reactivestreams.Publisher<? extends T> p4, org.reactivestreams.Publisher<? extends T> p5, org.reactivestreams.Publisher<? extends T> p6, org.reactivestreams.Publisher<? extends T> p7, org.reactivestreams.Publisher<? extends T> p8, org.reactivestreams.Publisher<? extends T> p9)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concatArray(int prefetch, org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> concatArray(org.reactivestreams.Publisher<? extends T>... sources)
Note: named this way because of overload conflict with concat(NbpObservable<NbpObservable>)
T - the common base value typesources - the array of sourcesjava.lang.NullPointerException - if sources is null@BackpressureSupport(value=NONE) @SchedulerSupport(value=NONE) public static <T> Observable<T> create(org.reactivestreams.Publisher<T> onSubscribe)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public static <T> Observable<T> defer(Supplier<? extends org.reactivestreams.Publisher<? extends T>> supplier)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public static <T> Observable<T> empty()
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public static <T> Observable<T> error(Supplier<? extends java.lang.Throwable> errorSupplier)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public static <T> Observable<T> error(java.lang.Throwable e)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> fromArray(T... values)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> fromCallable(java.util.concurrent.Callable<? extends T> supplier)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> fromFuture(java.util.concurrent.Future<? extends T> future)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> fromFuture(java.util.concurrent.Future<? extends T> future, long timeout, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public static <T> Observable<T> fromFuture(java.util.concurrent.Future<? extends T> future, long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=IO) public static <T> Observable<T> fromFuture(java.util.concurrent.Future<? extends T> future, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> fromIterable(java.lang.Iterable<? extends T> source)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public static <T> Observable<T> fromPublisher(org.reactivestreams.Publisher<? extends T> publisher)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> generate(Consumer<org.reactivestreams.Subscriber<T>> generator)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,S> Observable<T> generate(Supplier<S> initialState, BiConsumer<S,org.reactivestreams.Subscriber<T>> generator)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,S> Observable<T> generate(Supplier<S> initialState, BiConsumer<S,org.reactivestreams.Subscriber<T>> generator, Consumer<? super S> disposeState)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,S> Observable<T> generate(Supplier<S> initialState, BiFunction<S,org.reactivestreams.Subscriber<T>,S> generator)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,S> Observable<T> generate(Supplier<S> initialState, BiFunction<S,org.reactivestreams.Subscriber<T>,S> generator, Consumer<? super S> disposeState)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public static Observable<java.lang.Long> interval(long initialDelay, long period, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public static Observable<java.lang.Long> interval(long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public static Observable<java.lang.Long> interval(long period, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public static Observable<java.lang.Long> interval(long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public static Observable<java.lang.Long> intervalRange(long start, long count, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public static Observable<java.lang.Long> intervalRange(long start, long count, long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> just(T value)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> just(T v1, T v2)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> just(T v1, T v2, T v3)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> just(T v1, T v2, T v3, T v4)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> just(T v1, T v2, T v3, T v4, T v5)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> just(T v1, T v2, T v3, T v4, T v5, T v6)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> just(T v1, T v2, T v3, T v4, T v5, T v6, T v7)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> just(T v1, T v2, T v3, T v4, T v5, T v6, T v7, T v8)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static final <T> Observable<T> just(T v1, T v2, T v3, T v4, T v5, T v6, T v7, T v8, T v9)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(int maxConcurrency, int bufferSize, java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(int maxConcurrency, int bufferSize, org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(int maxConcurrency, org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources, int maxConcurrency)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources, int maxConcurrency)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> merge(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3, org.reactivestreams.Publisher<? extends T> p4)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(boolean delayErrors, java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(int maxConcurrency, int bufferSize, java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(int maxConcurrency, int bufferSize, org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(int maxConcurrency, java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(int maxConcurrency, org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources, int maxConcurrency)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> mergeDelayError(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, org.reactivestreams.Publisher<? extends T> p3, org.reactivestreams.Publisher<? extends T> p4)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public static <T> Observable<T> never()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static Observable<java.lang.Integer> range(int start, int count)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<java.lang.Boolean> sequenceEqual(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<java.lang.Boolean> sequenceEqual(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, BiPredicate<? super T,? super T> isEqual)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<java.lang.Boolean> sequenceEqual(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, BiPredicate<? super T,? super T> isEqual, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<java.lang.Boolean> sequenceEqual(org.reactivestreams.Publisher<? extends T> p1, org.reactivestreams.Publisher<? extends T> p2, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> switchOnNext(int bufferSize, org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T> Observable<T> switchOnNext(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public static Observable<java.lang.Long> timer(long delay, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public static Observable<java.lang.Long> timer(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public static <T,D> Observable<T> using(Supplier<? extends D> resourceSupplier, Function<? super D,? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier, Consumer<? super D> disposer)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public static <T,D> Observable<T> using(Supplier<? extends D> resourceSupplier, Function<? super D,? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier, Consumer<? super D> disposer, boolean eager)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> zip(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources, Function<? super java.lang.Object[],? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> zip(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources, Function<? super java.lang.Object[],? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, BiFunction<? super T1,? super T2,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, BiFunction<? super T1,? super T2,? extends R> zipper, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, BiFunction<? super T1,? super T2,? extends R> zipper, boolean delayError, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, Function3<? super T1,? super T2,? super T3,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, Function4<? super T1,? super T2,? super T3,? super T4,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,T6,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, org.reactivestreams.Publisher<? extends T6> p6, Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,T6,T7,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, org.reactivestreams.Publisher<? extends T6> p6, org.reactivestreams.Publisher<? extends T7> p7, Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,T6,T7,T8,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, org.reactivestreams.Publisher<? extends T6> p6, org.reactivestreams.Publisher<? extends T7> p7, org.reactivestreams.Publisher<? extends T8> p8, Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> Observable<R> zip(org.reactivestreams.Publisher<? extends T1> p1, org.reactivestreams.Publisher<? extends T2> p2, org.reactivestreams.Publisher<? extends T3> p3, org.reactivestreams.Publisher<? extends T4> p4, org.reactivestreams.Publisher<? extends T5> p5, org.reactivestreams.Publisher<? extends T6> p6, org.reactivestreams.Publisher<? extends T7> p7, org.reactivestreams.Publisher<? extends T8> p8, org.reactivestreams.Publisher<? extends T9> p9, Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> zipArray(Function<? super java.lang.Object[],? extends R> zipper, boolean delayError, int bufferSize, org.reactivestreams.Publisher<? extends T>... sources)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public static <T,R> Observable<R> zipIterable(Function<? super java.lang.Object[],? extends R> zipper, boolean delayError, int bufferSize, java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.lang.Boolean> all(Predicate<? super T> predicate)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> ambWith(org.reactivestreams.Publisher<? extends T> other)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.lang.Boolean> any(Predicate<? super T> predicate)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> asObservable()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> buffer(int count)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> buffer(int count, int skip)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U extends java.util.Collection<? super T>> Observable<U> buffer(int count, int skip, Supplier<U> bufferSupplier)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U extends java.util.Collection<? super T>> Observable<U> buffer(int count, Supplier<U> bufferSupplier)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<java.util.List<T>> buffer(long timespan, long timeskip, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<java.util.List<T>> buffer(long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final <U extends java.util.Collection<? super T>> Observable<U> buffer(long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler scheduler, Supplier<U> bufferSupplier)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final <U extends java.util.Collection<? super T>> Observable<U> buffer(long timespan, java.util.concurrent.TimeUnit unit, int count, Scheduler scheduler, Supplier<U> bufferSupplier, boolean restartTimerOnMaxSize)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<java.util.List<T>> buffer(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <TOpening,TClosing> Observable<java.util.List<T>> buffer(Observable<? extends TOpening> bufferOpenings, Function<? super TOpening,? extends org.reactivestreams.Publisher<? extends TClosing>> bufferClosingSelector)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <TOpening,TClosing,U extends java.util.Collection<? super T>> Observable<U> buffer(Observable<? extends TOpening> bufferOpenings, Function<? super TOpening,? extends org.reactivestreams.Publisher<? extends TClosing>> bufferClosingSelector, Supplier<U> bufferSupplier)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B> Observable<java.util.List<T>> buffer(org.reactivestreams.Publisher<B> boundary)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B> Observable<java.util.List<T>> buffer(org.reactivestreams.Publisher<B> boundary, int initialCapacity)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B,U extends java.util.Collection<? super T>> Observable<U> buffer(org.reactivestreams.Publisher<B> boundary, Supplier<U> bufferSupplier)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B> Observable<java.util.List<T>> buffer(Supplier<? extends org.reactivestreams.Publisher<B>> boundarySupplier)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B,U extends java.util.Collection<? super T>> Observable<U> buffer(Supplier<? extends org.reactivestreams.Publisher<B>> boundarySupplier, Supplier<U> bufferSupplier)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> cache()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> cache(int capacityHint)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final <U> Observable<U> cast(java.lang.Class<U> clazz)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <U> Observable<U> collect(Supplier<? extends U> initialValueSupplier, BiConsumer<? super U,? super T> collector)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <U> Observable<U> collectInto(U initialValue, BiConsumer<? super U,? super T> collector)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final <R> Observable<R> compose(Observable.Transformer<T,R> composer)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> concatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> concatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U> Observable<U> concatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U> Observable<U> concatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper, int prefetch)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> concatWith(org.reactivestreams.Publisher<? extends T> other)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.lang.Boolean> contains(java.lang.Object o)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.lang.Long> count()
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <U> Observable<T> debounce(Function<? super T,? extends org.reactivestreams.Publisher<U>> debounceSelector)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<T> debounce(long timeout, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<T> debounce(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> defaultIfEmpty(T value)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U> Observable<T> delay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=COMPUTATION) public final Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=COMPUTATION) public final Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> delay(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,V> Observable<T> delay(Supplier<? extends org.reactivestreams.Publisher<U>> delaySupplier, Function<? super T,? extends org.reactivestreams.Publisher<V>> itemDelay)
public final <U> Observable<T> delaySubscription(org.reactivestreams.Publisher<U> other)
Scheduler.U - the value type of the other Observable, irrelevantother - the other Observable that should trigger the subscription
to this Observable.@BackpressureSupport(value=FULL) @SchedulerSupport(value=COMPUTATION) public final Observable<T> delaySubscription(long delay, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> delaySubscription(long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U> Observable<T> delaySubscription(Supplier<? extends org.reactivestreams.Publisher<U>> delaySupplier)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <T2> Observable<T2> dematerialize()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> distinct()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <K> Observable<T> distinct(Function<? super T,K> keySelector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <K> Observable<T> distinct(Function<? super T,K> keySelector, Supplier<? extends java.util.Collection<? super K>> collectionSupplier)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> distinctUntilChanged()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <K> Observable<T> distinctUntilChanged(Function<? super T,K> keySelector)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnCancel(java.lang.Runnable onCancel)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnComplete(java.lang.Runnable onComplete)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnEach(Consumer<? super Try<Optional<T>>> consumer)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnEach(org.reactivestreams.Subscriber<? super T> observer)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnError(Consumer<? super java.lang.Throwable> onError)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnLifecycle(Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, java.lang.Runnable onCancel)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnNext(Consumer<? super T> onNext)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnRequest(LongConsumer onRequest)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnSubscribe(Consumer<? super org.reactivestreams.Subscription> onSubscribe)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> doOnTerminate(java.lang.Runnable onTerminate)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> elementAt(long index)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> elementAt(long index, T defaultValue)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> endWith(java.lang.Iterable<? extends T> values)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> endWith(org.reactivestreams.Publisher<? extends T> other)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> endWith(T value)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> endWithArray(T... values)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> filter(Predicate<? super T> predicate)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> finallyDo(java.lang.Runnable onFinally)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final Observable<T> first()
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final Observable<T> first(T defaultValue)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayErrors)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayErrors, int maxConcurrency)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> onNextMapper, Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends R>> onErrorMapper, Supplier<? extends org.reactivestreams.Publisher<? extends R>> onCompleteSupplier)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> onNextMapper, Function<java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends R>> onErrorMapper, Supplier<? extends org.reactivestreams.Publisher<? extends R>> onCompleteSupplier, int maxConcurrency)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int maxConcurrency)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> resultSelector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> combiner, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> combiner, boolean delayError, int maxConcurrency)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> combiner, boolean delayError, int maxConcurrency, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> combiner, int maxConcurrency)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U> Observable<U> flatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,V> Observable<V> flatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper, BiFunction<? super T,? super U,? extends V> resultSelector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U> Observable<U> flatMapIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper, int bufferSize)
@BackpressureSupport(value=NONE) @SchedulerSupport(value=NONE) public final Disposable forEach(Consumer<? super T> onNext)
@BackpressureSupport(value=NONE) @SchedulerSupport(value=NONE) public final Disposable forEachWhile(Predicate<? super T> onNext)
@BackpressureSupport(value=NONE) @SchedulerSupport(value=NONE) public final Disposable forEachWhile(Predicate<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
@BackpressureSupport(value=NONE) @SchedulerSupport(value=NONE) public final Disposable forEachWhile(Predicate<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <K> Observable<GroupedObservable<K,T>> groupBy(Function<? super T,? extends K> keySelector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <K> Observable<GroupedObservable<K,T>> groupBy(Function<? super T,? extends K> keySelector, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <K,V> Observable<GroupedObservable<K,V>> groupBy(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <K,V> Observable<GroupedObservable<K,V>> groupBy(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <K,V> Observable<GroupedObservable<K,V>> groupBy(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, boolean delayError, int bufferSize)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> ignoreElements()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.lang.Boolean> isEmpty()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> last()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> last(T defaultValue)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final <R> Observable<R> lift(Observable.Operator<? extends R,? super T> lifter)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final <R> Observable<R> map(Function<? super T,? extends R> mapper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<Try<Optional<T>>> materialize()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> mergeWith(org.reactivestreams.Publisher<? extends T> other)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) @Deprecated public final Observable<Observable<T>> nest()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> observeOn(Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> observeOn(Scheduler scheduler, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> observeOn(Scheduler scheduler, boolean delayError, int bufferSize)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final <U> Observable<U> ofType(java.lang.Class<U> clazz)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureBuffer()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureBuffer(boolean delayError)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureBuffer(int bufferSize)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureBuffer(int bufferSize, boolean delayError)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureBuffer(int bufferSize, boolean delayError, boolean unbounded)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureBuffer(int bufferSize, boolean delayError, boolean unbounded, java.lang.Runnable onOverflow)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureBuffer(int bufferSize, java.lang.Runnable onOverflow)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureDrop()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureDrop(Consumer<? super T> onDrop)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> onBackpressureLatest()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> onErrorResumeNext(Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends T>> resumeFunction)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> onErrorResumeNext(org.reactivestreams.Publisher<? extends T> next)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> onErrorReturn(Function<? super java.lang.Throwable,? extends T> valueSupplier)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> onErrorReturnValue(T value)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> onExceptionResumeNext(org.reactivestreams.Publisher<? extends T> next)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final ConnectableObservable<T> publish()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> publish(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> publish(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final ConnectableObservable<T> publish(int bufferSize)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> reduce(BiFunction<T,T,T> reducer)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <R> Observable<R> reduce(R seed, BiFunction<R,? super T,R> reducer)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <R> Observable<R> reduceWith(Supplier<R> seedSupplier, BiFunction<R,? super T,R> reducer)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> repeat()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> repeat(long times)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> repeatUntil(BooleanSupplier stop)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> repeatWhen(Function<? super Observable<java.lang.Object>,? extends org.reactivestreams.Publisher<?>> handler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final ConnectableObservable<T> replay()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=COMPUTATION) public final <R> Observable<R> replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final <R> Observable<R> replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector, int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final <R> Observable<R> replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector, int bufferSize, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=COMPUTATION) public final <R> Observable<R> replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector, long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final <R> Observable<R> replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final <R> Observable<R> replay(Function<? super Observable<T>,? extends org.reactivestreams.Publisher<R>> selector, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final ConnectableObservable<T> replay(int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=COMPUTATION) public final ConnectableObservable<T> replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final ConnectableObservable<T> replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final ConnectableObservable<T> replay(int bufferSize, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=COMPUTATION) public final ConnectableObservable<T> replay(long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final ConnectableObservable<T> replay(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final ConnectableObservable<T> replay(Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> retry()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> retry(BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> retry(long times)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> retry(long times, Predicate<? super java.lang.Throwable> predicate)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> retry(Predicate<? super java.lang.Throwable> predicate)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> retryUntil(BooleanSupplier stop)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> retryWhen(Function<? super Observable<? extends java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> handler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final void safeSubscribe(org.reactivestreams.Subscriber<? super T> s)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<T> sample(long period, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<T> sample(long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <U> Observable<T> sample(org.reactivestreams.Publisher<U> sampler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> scan(BiFunction<T,T,T> accumulator)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> scan(R seed, BiFunction<R,? super T,R> accumulator)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> scanWith(Supplier<R> seedSupplier, BiFunction<R,? super T,R> accumulator)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> serialize()
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> share()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> single()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<T> single(T defaultValue)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> skip(long n)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> skip(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> skipLast(int n)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=TRAMPOLINE) public final Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=TRAMPOLINE) public final Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit, boolean delayError)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=CUSTOM) public final Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=CUSTOM) public final Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean delayError)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=CUSTOM) public final Observable<T> skipLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean delayError, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U> Observable<T> skipUntil(org.reactivestreams.Publisher<U> other)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> skipWhile(Predicate<? super T> predicate)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> startWith(java.lang.Iterable<? extends T> values)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> startWith(org.reactivestreams.Publisher<? extends T> other)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> startWith(T value)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> startWithArray(T... values)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Disposable subscribe()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Disposable subscribe(Consumer<? super T> onNext)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, Consumer<? super org.reactivestreams.Subscription> onSubscribe)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final void subscribe(org.reactivestreams.Subscriber<? super T> s)
subscribe in interface org.reactivestreams.Publisher<T>@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=CUSTOM) public final Observable<T> subscribeOn(Scheduler scheduler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=CUSTOM) public final Observable<T> subscribeOn(Scheduler scheduler, boolean requestOn)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> switchIfEmpty(org.reactivestreams.Publisher<? extends T> other)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> switchMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <R> Observable<R> switchMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int bufferSize)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final Observable<T> take(long n)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> take(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final Observable<T> takeFirst(Predicate<? super T> predicate)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<T> takeLast(int n)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=TRAMPOLINE) public final Observable<T> takeLast(long count, long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> takeLast(long count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> takeLast(long count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean delayError, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=TRAMPOLINE) public final Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=TRAMPOLINE) public final Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> takeLast(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean delayError, int bufferSize)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> takeLastBuffer(int count)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=TRAMPOLINE) public final Observable<java.util.List<T>> takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<java.util.List<T>> takeLastBuffer(int count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=TRAMPOLINE) public final Observable<java.util.List<T>> takeLastBuffer(long time, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<java.util.List<T>> takeLastBuffer(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> takeUntil(Predicate<? super T> predicate)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final <U> Observable<T> takeUntil(org.reactivestreams.Publisher<U> other)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final Observable<T> takeWhile(Predicate<? super T> predicate)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<T> throttleFirst(long windowDuration, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<T> throttleFirst(long skipDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<T> throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<T> throttleLast(long intervalDuration, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<T> throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<T> throttleWithTimeout(long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=TRAMPOLINE) public final Observable<Timed<T>> timeInterval()
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=CUSTOM) public final Observable<Timed<T>> timeInterval(Scheduler scheduler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=TRAMPOLINE) public final Observable<Timed<T>> timeInterval(java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=CUSTOM) public final Observable<Timed<T>> timeInterval(java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final <V> Observable<T> timeout(Function<? super T,? extends org.reactivestreams.Publisher<V>> timeoutSelector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <V> Observable<T> timeout(Function<? super T,? extends org.reactivestreams.Publisher<V>> timeoutSelector, Observable<? extends T> other)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=COMPUTATION) public final Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=COMPUTATION) public final Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable<? extends T> other)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=CUSTOM) public final Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=CUSTOM) public final Observable<T> timeout(long timeout, java.util.concurrent.TimeUnit timeUnit, Scheduler scheduler)
public final <U,V> Observable<T> timeout(Supplier<? extends org.reactivestreams.Publisher<U>> firstTimeoutSelector, Function<? super T,? extends org.reactivestreams.Publisher<V>> timeoutSelector)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,V> Observable<T> timeout(Supplier<? extends org.reactivestreams.Publisher<U>> firstTimeoutSelector, Function<? super T,? extends org.reactivestreams.Publisher<V>> timeoutSelector, org.reactivestreams.Publisher<? extends T> other)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=TRAMPOLINE) public final Observable<Timed<T>> timestamp()
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=CUSTOM) public final Observable<Timed<T>> timestamp(Scheduler scheduler)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=TRAMPOLINE) public final Observable<Timed<T>> timestamp(java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=CUSTOM) public final Observable<Timed<T>> timestamp(java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final <R> R to(Function<? super Observable<T>,R> converter)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final BlockingObservable<T> toBlocking()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> toList()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> toList(int capacityHint)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <U extends java.util.Collection<? super T>> Observable<U> toList(Supplier<U> collectionSupplier)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <K> Observable<java.util.Map<K,T>> toMap(Function<? super T,? extends K> keySelector)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <K,V> Observable<java.util.Map<K,V>> toMap(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <K,V> Observable<java.util.Map<K,V>> toMap(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, Supplier<? extends java.util.Map<K,V>> mapSupplier)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <K> Observable<java.util.Map<K,java.util.Collection<T>>> toMultimap(Function<? super T,? extends K> keySelector)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, Supplier<? extends java.util.Map<K,java.util.Collection<V>>> mapSupplier, Function<? super K,? extends java.util.Collection<? super V>> collectionFactory)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final <K,V> Observable<java.util.Map<K,java.util.Collection<V>>> toMultimap(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, Supplier<java.util.Map<K,java.util.Collection<V>>> mapSupplier)
@BackpressureSupport(value=NONE) @SchedulerSupport(value=NONE) public final NbpObservable<T> toNbpObservable()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Single<T> toSingle()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> toSortedList()
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> toSortedList(java.util.Comparator<? super T> comparator)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> toSortedList(java.util.Comparator<? super T> comparator, int capacityHint)
@BackpressureSupport(value=UNBOUNDED_IN) @SchedulerSupport(value=NONE) public final Observable<java.util.List<T>> toSortedList(int capacityHint)
@BackpressureSupport(value=SPECIAL) @SchedulerSupport(value=NONE) public final void unsafeSubscribe(org.reactivestreams.Subscriber<? super T> s)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=CUSTOM) public final Observable<T> unsubscribeOn(Scheduler scheduler)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<Observable<T>> window(long count)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<Observable<T>> window(long count, long skip)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final Observable<Observable<T>> window(long count, long skip, int bufferSize)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<Observable<T>> window(long timespan, long timeskip, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<Observable<T>> window(long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<Observable<T>> window(long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler scheduler, int bufferSize)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, long count)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=COMPUTATION) public final Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, long count, boolean restart)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler, long count)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler, long count, boolean restart)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=CUSTOM) public final Observable<Observable<T>> window(long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler, long count, boolean restart, int bufferSize)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B> Observable<Observable<T>> window(org.reactivestreams.Publisher<B> boundary)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B> Observable<Observable<T>> window(org.reactivestreams.Publisher<B> boundary, int bufferSize)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <U,V> Observable<Observable<T>> window(org.reactivestreams.Publisher<U> windowOpen, Function<? super U,? extends org.reactivestreams.Publisher<V>> windowClose)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <U,V> Observable<Observable<T>> window(org.reactivestreams.Publisher<U> windowOpen, Function<? super U,? extends org.reactivestreams.Publisher<V>> windowClose, int bufferSize)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B> Observable<Observable<T>> window(Supplier<? extends org.reactivestreams.Publisher<B>> boundary)
@BackpressureSupport(value=ERROR) @SchedulerSupport(value=NONE) public final <B> Observable<Observable<T>> window(Supplier<? extends org.reactivestreams.Publisher<B>> boundary, int bufferSize)
@BackpressureSupport(value=PASS_THROUGH) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> withLatestFrom(org.reactivestreams.Publisher<? extends U> other, BiFunction<? super T,? super U,? extends R> combiner)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> zipWith(java.lang.Iterable<U> other, BiFunction<? super T,? super U,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> zipWith(org.reactivestreams.Publisher<? extends U> other, BiFunction<? super T,? super U,? extends R> zipper)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> zipWith(org.reactivestreams.Publisher<? extends U> other, BiFunction<? super T,? super U,? extends R> zipper, boolean delayError)
@BackpressureSupport(value=FULL) @SchedulerSupport(value=NONE) public final <U,R> Observable<R> zipWith(org.reactivestreams.Publisher<? extends U> other, BiFunction<? super T,? super U,? extends R> zipper, boolean delayError, int bufferSize)