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