final
Single<Boolean>
|
all(Predicate<? super T> predicate)
Returns an Observable that emits a Boolean that indicates whether all of the items emitted by the source
ObservableSource satisfy a condition.
|
static
<T>
Observable<T>
|
amb(Iterable<? extends ObservableSource<? extends T>> sources)
Mirrors the one ObservableSource in an Iterable of several ObservableSources that first either emits an item or sends
a termination notification.
|
static
<T>
Observable<T>
|
ambArray(ObservableSource...<? extends T> sources)
Mirrors the one ObservableSource in an array of several ObservableSources that first either emits an item or sends
a termination notification.
|
final
Observable<T>
|
ambWith(ObservableSource<? extends T> other)
Mirrors the ObservableSource (current or provided) that first either emits an item or sends a termination
notification.
|
final
Single<Boolean>
|
any(Predicate<? super T> predicate)
Returns an Observable that emits true if any item emitted by the source ObservableSource satisfies a
specified condition, otherwise false .
|
final
T
|
blockingFirst(T defaultItem)
Returns the first item emitted by this Observable , or a default value if it emits no
items.
|
final
T
|
blockingFirst()
Returns the first item emitted by this Observable , or throws
NoSuchElementException if it emits no items.
|
final
void
|
blockingForEach(Consumer<? super T> onNext)
Invokes a method on each item emitted by this Observable and blocks until the Observable
completes.
|
final
Iterable<T>
|
blockingIterable(int bufferSize)
Converts this Observable into an Iterable .
|
final
Iterable<T>
|
blockingIterable()
Converts this Observable into an Iterable .
|
final
T
|
blockingLast()
Returns the last item emitted by this Observable , or throws
NoSuchElementException if this Observable emits no items.
|
final
T
|
blockingLast(T defaultItem)
Returns the last item emitted by this Observable , or a default value if it emits no
items.
|
final
Iterable<T>
|
blockingLatest()
Returns an Iterable that returns the latest item emitted by this Observable ,
waiting if necessary for one to become available.
|
final
Iterable<T>
|
blockingMostRecent(T initialValue)
Returns an Iterable that always returns the item most recently emitted by this
Observable .
|
final
Iterable<T>
|
blockingNext()
Returns an Iterable that blocks until this Observable emits another item, then
returns that item.
|
final
T
|
blockingSingle(T defaultItem)
If this Observable completes after emitting a single item, return that item; if it emits
more than one item, throw an IllegalArgumentException ; if it emits no items, return a default
value.
|
final
T
|
blockingSingle()
If this Observable completes after emitting a single item, return that item, otherwise
throw a NoSuchElementException .
|
final
void
|
blockingSubscribe(Consumer<? super T> onNext)
Subscribes to the source and calls the given callbacks on the current thread.
|
final
void
|
blockingSubscribe(Observer<? super T> subscriber)
Subscribes to the source and calls the Observer methods on the current thread.
|
final
void
|
blockingSubscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError)
Subscribes to the source and calls the given callbacks on the current thread.
|
final
void
|
blockingSubscribe()
Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
|
final
void
|
blockingSubscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)
Subscribes to the source and calls the given callbacks on the current thread.
|
final
<TOpening, TClosing>
Observable<List<T>>
|
buffer(ObservableSource<? extends TOpening> openingIndicator, Function<? super TOpening, ? extends ObservableSource<? extends TClosing>> closingIndicator)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<TOpening, TClosing, U extends Collection<? super T>>
Observable<U>
|
buffer(ObservableSource<? extends TOpening> openingIndicator, Function<? super TOpening, ? extends ObservableSource<? extends TClosing>> closingIndicator, Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<U extends Collection<? super T>>
Observable<U>
|
buffer(long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
Observable<List<T>>
|
buffer(long timespan, long timeskip, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<U extends Collection<? super T>>
Observable<U>
|
buffer(int count, Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<B, U extends Collection<? super T>>
Observable<U>
|
buffer(Callable<? extends ObservableSource<B>> boundarySupplier, Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
Observable<List<T>>
|
buffer(long timespan, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<B>
Observable<List<T>>
|
buffer(ObservableSource<B> boundary, int initialCapacity)
Returns an Observable that emits non-overlapping buffered items from the source ObservableSource each time the
specified boundary ObservableSource emits an item.
|
final
Observable<List<T>>
|
buffer(int count)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<B>
Observable<List<T>>
|
buffer(Callable<? extends ObservableSource<B>> boundarySupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<B>
Observable<List<T>>
|
buffer(ObservableSource<B> boundary)
Returns an Observable that emits non-overlapping buffered items from the source ObservableSource each time the
specified boundary ObservableSource emits an item.
|
final
Observable<List<T>>
|
buffer(long timespan, long timeskip, TimeUnit unit)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
Observable<List<T>>
|
buffer(long timespan, TimeUnit unit, Scheduler scheduler, int count)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
Observable<List<T>>
|
buffer(long timespan, TimeUnit unit)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<U extends Collection<? super T>>
Observable<U>
|
buffer(long timespan, TimeUnit unit, Scheduler scheduler, int count, Callable<U> bufferSupplier, boolean restartTimerOnMaxSize)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<B, U extends Collection<? super T>>
Observable<U>
|
buffer(ObservableSource<B> boundary, Callable<U> bufferSupplier)
Returns an Observable that emits non-overlapping buffered items from the source ObservableSource each time the
specified boundary ObservableSource emits an item.
|
final
Observable<List<T>>
|
buffer(int count, int skip)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
Observable<List<T>>
|
buffer(long timespan, TimeUnit unit, int count)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
final
<U extends Collection<? super T>>
Observable<U>
|
buffer(int count, int skip, Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
static
int
|
bufferSize()
Returns the default 'island' size or capacity-increment hint for unbounded buffers.
|
final
Observable<T>
|
cache()
Returns an Observable that subscribes to this ObservableSource lazily, caches all of its events
and replays them, in the same order as received, to all the downstream subscribers.
|
final
Observable<T>
|
cacheWithInitialCapacity(int initialCapacity)
Returns an Observable that subscribes to this ObservableSource lazily, caches all of its events
and replays them, in the same order as received, to all the downstream subscribers.
|
final
<U>
Observable<U>
|
cast(Class<U> clazz)
Returns an Observable that emits the items emitted by the source ObservableSource, converted to the specified
type.
|
final
<U>
Single<U>
|
collect(Callable<? extends U> initialValueSupplier, BiConsumer<? super U, ? super T> collector)
Collects items emitted by the source ObservableSource into a single mutable data structure and returns
a Single that emits this structure.
|
final
<U>
Single<U>
|
collectInto(U initialValue, BiConsumer<? super U, ? super T> collector)
Collects items emitted by the source ObservableSource into a single mutable data structure and returns
a Single that emits this structure.
|
static
<T1, T2, T3, R>
Observable<R>
|
combineLatest(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, Function3<? super T1, ? super T2, ? super T3, ? extends R> combiner)
Combines three source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T1, T2, T3, T4, T5, T6, T7, T8, R>
Observable<R>
|
combineLatest(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, ObservableSource<? extends T6> source6, ObservableSource<? extends T7> source7, ObservableSource<? extends T8> source8, Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T, R>
Observable<R>
|
combineLatest(Iterable<? extends ObservableSource<? extends T>> sources, Function<? super Object[], ? extends R> combiner, int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T, R>
Observable<R>
|
combineLatest(Iterable<? extends ObservableSource<? extends T>> sources, Function<? super Object[], ? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T1, T2, T3, T4, T5, R>
Observable<R>
|
combineLatest(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> combiner)
Combines five source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T1, T2, R>
Observable<R>
|
combineLatest(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, BiFunction<? super T1, ? super T2, ? extends R> combiner)
Combines two source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from either of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T1, T2, T3, T4, R>
Observable<R>
|
combineLatest(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> combiner)
Combines four source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T, R>
Observable<R>
|
combineLatest(ObservableSource[]<? extends T> sources, Function<? super Object[], ? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T1, T2, T3, T4, T5, T6, T7, R>
Observable<R>
|
combineLatest(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, ObservableSource<? extends T6> source6, ObservableSource<? extends T7> source7, Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> combiner)
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T, R>
Observable<R>
|
combineLatest(ObservableSource[]<? extends T> sources, Function<? super Object[], ? extends R> combiner, int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T1, T2, T3, T4, T5, T6, R>
Observable<R>
|
combineLatest(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, ObservableSource<? extends T6> source6, Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> combiner)
Combines six source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T, R>
Observable<R>
|
combineLatest(Function<? super Object[], ? extends R> combiner, int bufferSize, ObservableSource...<? extends T> sources)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>
Observable<R>
|
combineLatest(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, ObservableSource<? extends T6> source6, ObservableSource<? extends T7> source7, ObservableSource<? extends T8> source8, ObservableSource<? extends T9> source9, Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static
<T, R>
Observable<R>
|
combineLatestDelayError(Iterable<? extends ObservableSource<? extends T>> sources, Function<? super Object[], ? extends R> combiner, int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static
<T, R>
Observable<R>
|
combineLatestDelayError(Function<? super Object[], ? extends R> combiner, int bufferSize, ObservableSource...<? extends T> sources)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static
<T, R>
Observable<R>
|
combineLatestDelayError(Iterable<? extends ObservableSource<? extends T>> sources, Function<? super Object[], ? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static
<T, R>
Observable<R>
|
combineLatestDelayError(ObservableSource[]<? extends T> sources, Function<? super Object[], ? extends R> combiner, int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static
<T, R>
Observable<R>
|
combineLatestDelayError(ObservableSource[]<? extends T> sources, Function<? super Object[], ? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
final
<R>
Observable<R>
|
compose(ObservableTransformer<? super T, ? extends R> composer)
Transform an ObservableSource by applying a particular Transformer function to it.
|
static
<T>
Observable<T>
|
concat(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, ObservableSource<? extends T> source3)
Returns an Observable that emits the items emitted by three ObservableSources, one after the other, without
interleaving them.
|
static
<T>
Observable<T>
|
concat(ObservableSource<? extends ObservableSource<? extends T>> sources, int prefetch)
Returns an Observable that emits the items emitted by each of the ObservableSources emitted by the source
ObservableSource, one after the other, without interleaving them.
|
static
<T>
Observable<T>
|
concat(ObservableSource<? extends ObservableSource<? extends T>> sources)
Returns an Observable that emits the items emitted by each of the ObservableSources emitted by the source
ObservableSource, one after the other, without interleaving them.
|
static
<T>
Observable<T>
|
concat(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2)
Returns an Observable that emits the items emitted by two ObservableSources, one after the other, without
interleaving them.
|
static
<T>
Observable<T>
|
concat(Iterable<? extends ObservableSource<? extends T>> sources)
Concatenates elements of each ObservableSource provided via an Iterable sequence into a single sequence
of elements without interleaving them.
|
static
<T>
Observable<T>
|
concat(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, ObservableSource<? extends T> source3, ObservableSource<? extends T> source4)
Returns an Observable that emits the items emitted by four ObservableSources, one after the other, without
interleaving them.
|
static
<T>
Observable<T>
|
concatArray(ObservableSource...<? extends T> sources)
Concatenates a variable number of ObservableSource sources.
|
static
<T>
Observable<T>
|
concatArrayDelayError(ObservableSource...<? extends T> sources)
Concatenates a variable number of ObservableSource sources and delays errors from any of them
till all terminate.
|
static
<T>
Observable<T>
|
concatArrayEager(ObservableSource...<? extends T> sources)
Concatenates a sequence of ObservableSources eagerly into a single stream of values.
|
static
<T>
Observable<T>
|
concatArrayEager(int maxConcurrency, int prefetch, ObservableSource...<? extends T> sources)
Concatenates a sequence of ObservableSources eagerly into a single stream of values.
|
static
<T>
Observable<T>
|
concatDelayError(Iterable<? extends ObservableSource<? extends T>> sources)
Concatenates the Iterable sequence of ObservableSources into a single sequence by subscribing to each ObservableSource,
one after the other, one at a time and delays any errors till the all inner ObservableSources terminate.
|
static
<T>
Observable<T>
|
concatDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources, int prefetch, boolean tillTheEnd)
Concatenates the ObservableSource sequence of ObservableSources into a single sequence by subscribing to each inner ObservableSource,
one after the other, one at a time and delays any errors till the all inner and the outer ObservableSources terminate.
|
static
<T>
Observable<T>
|
concatDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Concatenates the ObservableSource sequence of ObservableSources into a single sequence by subscribing to each inner ObservableSource,
one after the other, one at a time and delays any errors till the all inner and the outer ObservableSources terminate.
|
static
<T>
Observable<T>
|
concatEager(ObservableSource<? extends ObservableSource<? extends T>> sources, int maxConcurrency, int prefetch)
Concatenates an ObservableSource sequence of ObservableSources eagerly into a single stream of values.
|
static
<T>
Observable<T>
|
concatEager(Iterable<? extends ObservableSource<? extends T>> sources, int maxConcurrency, int prefetch)
Concatenates a sequence of ObservableSources eagerly into a single stream of values.
|
static
<T>
Observable<T>
|
concatEager(Iterable<? extends ObservableSource<? extends T>> sources)
Concatenates a sequence of ObservableSources eagerly into a single stream of values.
|
static
<T>
Observable<T>
|
concatEager(ObservableSource<? extends ObservableSource<? extends T>> sources)
Concatenates an ObservableSource sequence of ObservableSources eagerly into a single stream of values.
|
final
<R>
Observable<R>
|
concatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper, int prefetch)
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the source ObservableSource, where that function returns an ObservableSource, and then emitting the items
that result from concatenating those resulting ObservableSources.
|
final
<R>
Observable<R>
|
concatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper)
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the source ObservableSource, where that function returns an ObservableSource, and then emitting the items
that result from concatenating those resulting ObservableSources.
|
final
<R>
Observable<R>
|
concatMapDelayError(Function<? super T, ? extends ObservableSource<? extends R>> mapper)
Maps each of the items into an ObservableSource, subscribes to them one after the other,
one at a time and emits their values in order
while delaying any error from either this or any of the inner ObservableSources
till all of them terminate.
|
final
<R>
Observable<R>
|
concatMapDelayError(Function<? super T, ? extends ObservableSource<? extends R>> mapper, int prefetch, boolean tillTheEnd)
Maps each of the items into an ObservableSource, subscribes to them one after the other,
one at a time and emits their values in order
while delaying any error from either this or any of the inner ObservableSources
till all of them terminate.
|
final
<R>
Observable<R>
|
concatMapEager(Function<? super T, ? extends ObservableSource<? extends R>> mapper)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
final
<R>
Observable<R>
|
concatMapEager(Function<? super T, ? extends ObservableSource<? extends R>> mapper, int maxConcurrency, int prefetch)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
final
<R>
Observable<R>
|
concatMapEagerDelayError(Function<? super T, ? extends ObservableSource<? extends R>> mapper, boolean tillTheEnd)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
final
<R>
Observable<R>
|
concatMapEagerDelayError(Function<? super T, ? extends ObservableSource<? extends R>> mapper, int maxConcurrency, int prefetch, boolean tillTheEnd)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
final
<U>
Observable<U>
|
concatMapIterable(Function<? super T, ? extends Iterable<? extends U>> mapper)
Returns an Observable that concatenate each item emitted by the source ObservableSource with the values in an
Iterable corresponding to that item that is generated by a selector.
|
final
<U>
Observable<U>
|
concatMapIterable(Function<? super T, ? extends Iterable<? extends U>> mapper, int prefetch)
Returns an Observable that concatenate each item emitted by the source ObservableSource with the values in an
Iterable corresponding to that item that is generated by a selector.
|
final
Observable<T>
|
concatWith(ObservableSource<? extends T> other)
Returns an Observable that emits the items emitted from the current ObservableSource, then the next, one after
the other, without interleaving them.
|
final
Single<Boolean>
|
contains(Object element)
Returns an Observable that emits a Boolean that indicates whether the source ObservableSource emitted a
specified item.
|
final
Single<Long>
|
count()
Returns a Single that counts the total number of items emitted by the source ObservableSource and emits
this count as a 64-bit Long.
|
static
<T>
Observable<T>
|
create(ObservableOnSubscribe<T> source)
Provides an API (via a cold Observable) that bridges the reactive world with the callback-style world.
|
final
Observable<T>
|
debounce(long timeout, TimeUnit unit)
Returns an Observable that mirrors the source ObservableSource, except that it drops items emitted by the
source ObservableSource that are followed by newer items before a timeout value expires.
|
final
Observable<T>
|
debounce(long timeout, TimeUnit unit, Scheduler scheduler)
Returns an Observable that mirrors the source ObservableSource, except that it drops items emitted by the
source ObservableSource that are followed by newer items before a timeout value expires on a specified
Scheduler.
|
final
<U>
Observable<T>
|
debounce(Function<? super T, ? extends ObservableSource<U>> debounceSelector)
Returns an Observable that mirrors the source ObservableSource, except that it drops items emitted by the
source ObservableSource that are followed by another item within a computed debounce duration.
|
final
Observable<T>
|
defaultIfEmpty(T defaultItem)
Returns an Observable that emits the items emitted by the source ObservableSource or a specified default item
if the source ObservableSource is empty.
|
static
<T>
Observable<T>
|
defer(Callable<? extends ObservableSource<? extends T>> supplier)
Returns an Observable that calls an ObservableSource factory to create an ObservableSource for each new Observer
that subscribes.
|
final
Observable<T>
|
delay(long delay, TimeUnit unit, boolean delayError)
Returns an Observable that emits the items emitted by the source ObservableSource shifted forward in time by a
specified delay.
|
final
Observable<T>
|
delay(long delay, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits the items emitted by the source ObservableSource shifted forward in time by a
specified delay.
|
final
Observable<T>
|
delay(long delay, TimeUnit unit, Scheduler scheduler, boolean delayError)
Returns an Observable that emits the items emitted by the source ObservableSource shifted forward in time by a
specified delay.
|
final
<U>
Observable<T>
|
delay(Function<? super T, ? extends ObservableSource<U>> itemDelay)
Returns an Observable that delays the emissions of the source ObservableSource via another ObservableSource on a
per-item basis.
|
final
<U, V>
Observable<T>
|
delay(ObservableSource<U> subscriptionDelay, Function<? super T, ? extends ObservableSource<V>> itemDelay)
Returns an Observable that delays the subscription to and emissions from the source ObservableSource via another
ObservableSource on a per-item basis.
|
final
Observable<T>
|
delay(long delay, TimeUnit unit)
Returns an Observable that emits the items emitted by the source ObservableSource shifted forward in time by a
specified delay.
|
final
Observable<T>
|
delaySubscription(long delay, TimeUnit unit, Scheduler scheduler)
Returns an Observable that delays the subscription to the source ObservableSource by a given amount of time,
both waiting and subscribing on a given Scheduler.
|
final
Observable<T>
|
delaySubscription(long delay, TimeUnit unit)
Returns an Observable that delays the subscription to the source ObservableSource by a given amount of time.
|
final
<U>
Observable<T>
|
delaySubscription(ObservableSource<U> other)
Returns an Observable that delays the subscription to this Observable
until the other Observable emits an element or completes normally.
|
final
<T2>
Observable<T2>
|
dematerialize()
Returns an Observable that reverses the effect of materialize by transforming the
Notification objects emitted by the source ObservableSource into the items or notifications they
represent.
|
final
Observable<T>
|
distinct()
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct.
|
final
<K>
Observable<T>
|
distinct(Function<? super T, K> keySelector)
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct according
to a key selector function.
|
final
<K>
Observable<T>
|
distinct(Function<? super T, K> keySelector, Callable<? extends Collection<? super K>> collectionSupplier)
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct according
to a key selector function.
|
final
Observable<T>
|
distinctUntilChanged(BiPredicate<? super T, ? super T> comparer)
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct from their
immediate predecessors when compared with each other via the provided comparator function.
|
final
<K>
Observable<T>
|
distinctUntilChanged(Function<? super T, K> keySelector)
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct from their
immediate predecessors, according to a key selector function.
|
final
Observable<T>
|
distinctUntilChanged()
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct from their
immediate predecessors.
|
final
Observable<T>
|
doAfterNext(Consumer<? super T> onAfterNext)
Calls the specified consumer with the current item after this item has been emitted to the downstream.
|
final
Observable<T>
|
doAfterTerminate(Action onFinally)
|
final
Observable<T>
|
doFinally(Action onFinally)
Calls the specified action after this Observable signals onError or onCompleted or gets disposed by
the downstream.
|
final
Observable<T>
|
doOnComplete(Action onComplete)
Modifies the source ObservableSource so that it invokes an action when it calls onComplete .
|
final
Observable<T>
|
doOnDispose(Action onDispose)
Calls the dispose Action if the downstream disposes the sequence.
|
final
Observable<T>
|
doOnEach(Observer<? super T> observer)
Modifies the source ObservableSource so that it notifies an Observer for each item and terminal event it emits.
|
final
Observable<T>
|
doOnEach(Consumer<? super Notification<T>> onNotification)
Modifies the source ObservableSource so that it invokes an action for each item it emits.
|
final
Observable<T>
|
doOnError(Consumer<? super Throwable> onError)
Modifies the source ObservableSource so that it invokes an action if it calls onError .
|
final
Observable<T>
|
doOnLifecycle(Consumer<? super Disposable> onSubscribe, Action onDispose)
Calls the appropriate onXXX method (shared between all Observer) for the lifecycle events of
the sequence (subscription, cancellation, requesting).
|
final
Observable<T>
|
doOnNext(Consumer<? super T> onNext)
Modifies the source ObservableSource so that it invokes an action when it calls onNext .
|
final
Observable<T>
|
doOnSubscribe(Consumer<? super Disposable> onSubscribe)
Modifies the source ObservableSource so that it invokes the given action when it is subscribed from
its subscribers.
|
final
Observable<T>
|
doOnTerminate(Action onTerminate)
Modifies the source ObservableSource so that it invokes an action when it calls onComplete or
onError .
|
final
Single<T>
|
elementAt(long index, T defaultItem)
Returns a Single that emits the item found at a specified index in a sequence of emissions from
this Observable, or a default item if that index is out of range.
|
final
Maybe<T>
|
elementAt(long index)
Returns a Maybe that emits the single item at a specified index in a sequence of emissions from
this Observable or completes if this Observable signals fewer elements than index.
|
final
Single<T>
|
elementAtOrError(long index)
Returns a Single that emits the item found at a specified index in a sequence of emissions from this Observable
or signals a NoSuchElementException if this Observable signals fewer elements than index.
|
static
<T>
Observable<T>
|
empty()
Returns an Observable that emits no items to the Observer and immediately invokes its
onComplete method.
|
static
<T>
Observable<T>
|
error(Callable<? extends Throwable> errorSupplier)
Returns an Observable that invokes an Observer 's onError method when the
Observer subscribes to it.
|
static
<T>
Observable<T>
|
error(Throwable exception)
Returns an Observable that invokes an Observer 's onError method when the
Observer subscribes to it.
|
final
Observable<T>
|
filter(Predicate<? super T> predicate)
Filters items emitted by an ObservableSource by only emitting those that satisfy a specified predicate.
|
final
Single<T>
|
first(T defaultItem)
Returns a Single that emits only the very first item emitted by the source ObservableSource, or a default item
if the source ObservableSource completes without emitting any items.
|
final
Maybe<T>
|
firstElement()
Returns a Maybe that emits only the very first item emitted by the source ObservableSource, or
completes if the source ObservableSource is empty.
|
final
Single<T>
|
firstOrError()
Returns a Single that emits only the very first item emitted by this Observable or
signals a NoSuchElementException if this Observable is empty.
|
final
<U, R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner, boolean delayErrors, int maxConcurrency, int bufferSize)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
final
<R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger.
|
final
<R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends R>> onNextMapper, Function<Throwable, ? extends ObservableSource<? extends R>> onErrorMapper, Callable<? extends ObservableSource<? extends R>> onCompleteSupplier, int maxConcurrency)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these ObservableSources.
|
final
<U, R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner, int maxConcurrency)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
final
<R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper, boolean delayErrors)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger.
|
final
<U, R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner, boolean delayErrors)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource.
|
final
<R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends R>> onNextMapper, Function<? super Throwable, ? extends ObservableSource<? extends R>> onErrorMapper, Callable<? extends ObservableSource<? extends R>> onCompleteSupplier)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items.
|
final
<U, R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner, boolean delayErrors, int maxConcurrency)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
final
<R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
final
<R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper, boolean delayErrors, int maxConcurrency)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
final
<R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper, int maxConcurrency)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
final
<U, R>
Observable<R>
|
flatMap(Function<? super T, ? extends ObservableSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource.
|
final
Completable
|
flatMapCompletable(Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors)
Maps each element of the upstream Observable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete, optionally delaying all errors.
|
final
Completable
|
flatMapCompletable(Function<? super T, ? extends CompletableSource> mapper)
Maps each element of the upstream Observable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete.
|
final
<U, V>
Observable<V>
|
flatMapIterable(Function<? super T, ? extends Iterable<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends V> resultSelector)
Returns an Observable that emits the results of applying a function to the pair of values from the source
ObservableSource and an Iterable corresponding to that item that is generated by a selector.
|
final
<U>
Observable<U>
|
flatMapIterable(Function<? super T, ? extends Iterable<? extends U>> mapper)
Returns an Observable that merges each item emitted by the source ObservableSource with the values in an
Iterable corresponding to that item that is generated by a selector.
|
final
<R>
Observable<R>
|
flatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors)
Maps each element of the upstream Observable into MaybeSources, subscribes to them and
waits until the upstream and all MaybeSources complete, optionally delaying all errors.
|
final
<R>
Observable<R>
|
flatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>> mapper)
Maps each element of the upstream Observable into MaybeSources, subscribes to them and
waits until the upstream and all MaybeSources complete.
|
final
<R>
Observable<R>
|
flatMapSingle(Function<? super T, ? extends SingleSource<? extends R>> mapper)
Maps each element of the upstream Observable into SingleSources, subscribes to them and
waits until the upstream and all SingleSources complete.
|
final
<R>
Observable<R>
|
flatMapSingle(Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors)
Maps each element of the upstream Observable into SingleSources, subscribes to them and
waits until the upstream and all SingleSources complete, optionally delaying all errors.
|
final
Disposable
|
forEach(Consumer<? super T> onNext)
|
final
Disposable
|
forEachWhile(Predicate<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)
Subscribes to the ObservableSource and receives notifications for each element and the terminal events until the
onNext Predicate returns false.
|
final
Disposable
|
forEachWhile(Predicate<? super T> onNext, Consumer<? super Throwable> onError)
Subscribes to the ObservableSource and receives notifications for each element and error events until the
onNext Predicate returns false.
|
final
Disposable
|
forEachWhile(Predicate<? super T> onNext)
Subscribes to the ObservableSource and receives notifications for each element until the
onNext Predicate returns false.
|
static
<T>
Observable<T>
|
fromArray(T... items)
Converts an Array into an ObservableSource that emits the items in the Array.
|
static
<T>
Observable<T>
|
fromCallable(Callable<? extends T> supplier)
Returns an Observable that, when an observer subscribes to it, invokes a function you specify and then
emits the value returned from that function.
|
static
<T>
Observable<T>
|
fromFuture(Future<? extends T> future, Scheduler scheduler)
Converts a Future , operating on a specified Scheduler , into an ObservableSource.
|
static
<T>
Observable<T>
|
fromFuture(Future<? extends T> future, long timeout, TimeUnit unit, Scheduler scheduler)
Converts a Future into an ObservableSource, with a timeout on the Future.
|
static
<T>
Observable<T>
|
fromFuture(Future<? extends T> future, long timeout, TimeUnit unit)
Converts a Future into an ObservableSource, with a timeout on the Future.
|
static
<T>
Observable<T>
|
fromFuture(Future<? extends T> future)
Converts a Future into an ObservableSource.
|
static
<T>
Observable<T>
|
fromIterable(Iterable<? extends T> source)
Converts an Iterable sequence into an ObservableSource that emits the items in the sequence.
|
static
<T>
Observable<T>
|
fromPublisher(Publisher<? extends T> publisher)
Converts an arbitrary Reactive-Streams Publisher into an Observable.
|
static
<T, S>
Observable<T>
|
generate(Callable<S> initialState, BiFunction<S, Emitter<T>, S> generator, Consumer<? super S> disposeState)
Returns a cold, synchronous and stateful generator of values.
|
static
<T, S>
Observable<T>
|
generate(Callable<S> initialState, BiFunction<S, Emitter<T>, S> generator)
Returns a cold, synchronous and stateful generator of values.
|
static
<T, S>
Observable<T>
|
generate(Callable<S> initialState, BiConsumer<S, Emitter<T>> generator)
Returns a cold, synchronous and stateful generator of values.
|
static
<T, S>
Observable<T>
|
generate(Callable<S> initialState, BiConsumer<S, Emitter<T>> generator, Consumer<? super S> disposeState)
Returns a cold, synchronous and stateful generator of values.
|
static
<T>
Observable<T>
|
generate(Consumer<Emitter<T>> generator)
Returns a cold, synchronous and stateless generator of values.
|
final
<K>
Observable<GroupedObservable<K, T>>
|
groupBy(Function<? super T, ? extends K> keySelector, boolean delayError)
Groups the items emitted by an ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
final
<K>
Observable<GroupedObservable<K, T>>
|
groupBy(Function<? super T, ? extends K> keySelector)
Groups the items emitted by an ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
final
<K, V>
Observable<GroupedObservable<K, V>>
|
groupBy(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector)
Groups the items emitted by an ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
final
<K, V>
Observable<GroupedObservable<K, V>>
|
groupBy(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, boolean delayError)
Groups the items emitted by an ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
final
<K, V>
Observable<GroupedObservable<K, V>>
|
groupBy(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, boolean delayError, int bufferSize)
Groups the items emitted by an ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
final
<TRight, TLeftEnd, TRightEnd, R>
Observable<R>
|
groupJoin(ObservableSource<? extends TRight> other, Function<? super T, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super T, ? super Observable<TRight>, ? extends R> resultSelector)
Returns an Observable that correlates two ObservableSources when they overlap in time and groups the results.
|
final
Observable<T>
|
hide()
Hides the identity of this Observable and its Disposable.
|
final
Completable
|
ignoreElements()
Ignores all items emitted by the source ObservableSource and only calls onComplete or onError .
|
static
Observable<Long>
|
interval(long period, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits a sequential number every specified interval of time, on a
specified Scheduler.
|
static
Observable<Long>
|
interval(long period, TimeUnit unit)
Returns an Observable that emits a sequential number every specified interval of time.
|
static
Observable<Long>
|
interval(long initialDelay, long period, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits a 0L after the initialDelay and ever increasing numbers
after each period of time thereafter, on a specified Scheduler .
|
static
Observable<Long>
|
interval(long initialDelay, long period, TimeUnit unit)
Returns an Observable that emits a 0L after the initialDelay and ever increasing numbers
after each period of time thereafter.
|
static
Observable<Long>
|
intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit, Scheduler scheduler)
Signals a range of long values, the first after some initial delay and the rest periodically after.
|
static
Observable<Long>
|
intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit)
Signals a range of long values, the first after some initial delay and the rest periodically after.
|
final
Single<Boolean>
|
isEmpty()
Returns an Observable that emits true if the source ObservableSource is empty, otherwise false .
|
final
<TRight, TLeftEnd, TRightEnd, R>
Observable<R>
|
join(ObservableSource<? extends TRight> other, Function<? super T, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super T, ? super TRight, ? extends R> resultSelector)
Correlates the items emitted by two ObservableSources based on overlapping durations.
|
static
<T>
Observable<T>
|
just(T item1, T item2, T item3, T item4, T item5, T item6)
Converts six items into an ObservableSource that emits those items.
|
static
<T>
Observable<T>
|
just(T item1, T item2)
Converts two items into an ObservableSource that emits those items.
|
static
<T>
Observable<T>
|
just(T item1, T item2, T item3, T item4)
Converts four items into an ObservableSource that emits those items.
|
static
<T>
Observable<T>
|
just(T item)
Returns an Observable that emits a single item and then completes.
|
static
<T>
Observable<T>
|
just(T item1, T item2, T item3, T item4, T item5)
Converts five items into an ObservableSource that emits those items.
|
static
<T>
Observable<T>
|
just(T item1, T item2, T item3, T item4, T item5, T item6, T item7)
Converts seven items into an ObservableSource that emits those items.
|
static
<T>
Observable<T>
|
just(T item1, T item2, T item3, T item4, T item5, T item6, T item7, T item8)
Converts eight items into an ObservableSource that emits those items.
|
static
<T>
Observable<T>
|
just(T item1, T item2, T item3, T item4, T item5, T item6, T item7, T item8, T item9)
Converts nine items into an ObservableSource that emits those items.
|
static
<T>
Observable<T>
|
just(T item1, T item2, T item3, T item4, T item5, T item6, T item7, T item8, T item9, T item10)
Converts ten items into an ObservableSource that emits those items.
|
static
<T>
Observable<T>
|
just(T item1, T item2, T item3)
Converts three items into an ObservableSource that emits those items.
|
final
Single<T>
|
last(T defaultItem)
Returns a Single that emits only the last item emitted by this Observable, or a default item
if this Observable completes without emitting any items.
|
final
Maybe<T>
|
lastElement()
Returns a Maybe that emits the last item emitted by this Observable or
completes if this Observable is empty.
|
final
Single<T>
|
lastOrError()
Returns a Single that emits only the last item emitted by this Observable or
signals a NoSuchElementException if this Observable is empty.
|
final
<R>
Observable<R>
|
lift(ObservableOperator<? extends R, ? super T> lifter)
This method requires advanced knowledge about building operators; please consider
other standard composition methods first;
Lifts a function to the current ObservableSource and returns a new ObservableSource that when subscribed to will pass
the values of the current ObservableSource through the Operator function.
|
final
<R>
Observable<R>
|
map(Function<? super T, ? extends R> mapper)
Returns an Observable that applies a specified function to each item emitted by the source ObservableSource and
emits the results of these function applications.
|
final
Observable<Notification<T>>
|
materialize()
Returns an Observable that represents all of the emissions and notifications from the source
ObservableSource into emissions marked with their original types within Notification objects.
|
static
<T>
Observable<T>
|
merge(Iterable<? extends ObservableSource<? extends T>> sources)
Flattens an Iterable of ObservableSources into one ObservableSource, without any transformation.
|
static
<T>
Observable<T>
|
merge(ObservableSource<? extends ObservableSource<? extends T>> sources)
Flattens an ObservableSource that emits ObservableSources into a single ObservableSource that emits the items emitted by
those ObservableSources, without any transformation.
|
static
<T>
Observable<T>
|
merge(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2)
Flattens two ObservableSources into a single ObservableSource, without any transformation.
|
static
<T>
Observable<T>
|
merge(Iterable<? extends ObservableSource<? extends T>> sources, int maxConcurrency, int bufferSize)
Flattens an Iterable of ObservableSources into one ObservableSource, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
static
<T>
Observable<T>
|
merge(Iterable<? extends ObservableSource<? extends T>> sources, int maxConcurrency)
Flattens an Iterable of ObservableSources into one ObservableSource, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
static
<T>
Observable<T>
|
merge(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, ObservableSource<? extends T> source3)
Flattens three ObservableSources into a single ObservableSource, without any transformation.
|
static
<T>
Observable<T>
|
merge(ObservableSource<? extends ObservableSource<? extends T>> sources, int maxConcurrency)
Flattens an ObservableSource that emits ObservableSources into a single ObservableSource that emits the items emitted by
those ObservableSources, without any transformation, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
static
<T>
Observable<T>
|
merge(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, ObservableSource<? extends T> source3, ObservableSource<? extends T> source4)
Flattens four ObservableSources into a single ObservableSource, without any transformation.
|
static
<T>
Observable<T>
|
mergeArray(int maxConcurrency, int bufferSize, ObservableSource...<? extends T> sources)
Flattens an Iterable of ObservableSources into one ObservableSource, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
static
<T>
Observable<T>
|
mergeArray(ObservableSource...<? extends T> sources)
Flattens an Array of ObservableSources into one ObservableSource, without any transformation.
|
static
<T>
Observable<T>
|
mergeArrayDelayError(ObservableSource...<? extends T> sources)
Flattens an Iterable of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static
<T>
Observable<T>
|
mergeArrayDelayError(int maxConcurrency, int bufferSize, ObservableSource...<? extends T> sources)
Flattens an array of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
|
static
<T>
Observable<T>
|
mergeDelayError(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, ObservableSource<? extends T> source3, ObservableSource<? extends T> source4)
Flattens four ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static
<T>
Observable<T>
|
mergeDelayError(Iterable<? extends ObservableSource<? extends T>> sources)
Flattens an Iterable of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static
<T>
Observable<T>
|
mergeDelayError(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2)
Flattens two ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static
<T>
Observable<T>
|
mergeDelayError(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, ObservableSource<? extends T> source3)
Flattens three ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static
<T>
Observable<T>
|
mergeDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Flattens an ObservableSource that emits ObservableSources into one ObservableSource, in a way that allows an Observer to
receive all successfully emitted items from all of the source ObservableSources without being interrupted by
an error notification from one of them.
|
static
<T>
Observable<T>
|
mergeDelayError(Iterable<? extends ObservableSource<? extends T>> sources, int maxConcurrency, int bufferSize)
Flattens an Iterable of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
|
static
<T>
Observable<T>
|
mergeDelayError(Iterable<? extends ObservableSource<? extends T>> sources, int maxConcurrency)
Flattens an Iterable of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
|
static
<T>
Observable<T>
|
mergeDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources, int maxConcurrency)
Flattens an ObservableSource that emits ObservableSources into one ObservableSource, in a way that allows an Observer to
receive all successfully emitted items from all of the source ObservableSources without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
final
Observable<T>
|
mergeWith(ObservableSource<? extends T> other)
Flattens this and another ObservableSource into a single ObservableSource, without any transformation.
|
static
<T>
Observable<T>
|
never()
Returns an Observable that never sends any items or notifications to an Observer .
|
final
Observable<T>
|
observeOn(Scheduler scheduler, boolean delayError)
Modifies an ObservableSource to perform its emissions and notifications on a specified Scheduler ,
asynchronously with an unbounded buffer with bufferSize() "island size" and optionally delays onError notifications.
|
final
Observable<T>
|
observeOn(Scheduler scheduler)
Modifies an ObservableSource to perform its emissions and notifications on a specified Scheduler ,
asynchronously with an unbounded buffer with bufferSize() "island size".
|
final
Observable<T>
|
observeOn(Scheduler scheduler, boolean delayError, int bufferSize)
Modifies an ObservableSource to perform its emissions and notifications on a specified Scheduler ,
asynchronously with an unbounded buffer of configurable "island size" and optionally delays onError notifications.
|
final
<U>
Observable<U>
|
ofType(Class<U> clazz)
Filters the items emitted by an ObservableSource, only emitting those of the specified type.
|
final
Observable<T>
|
onErrorResumeNext(Function<? super Throwable, ? extends ObservableSource<? extends T>> resumeFunction)
Instructs an ObservableSource to pass control to another ObservableSource rather than invoking
onError if it encounters an error.
|
final
Observable<T>
|
onErrorResumeNext(ObservableSource<? extends T> next)
Instructs an ObservableSource to pass control to another ObservableSource rather than invoking
onError if it encounters an error.
|
final
Observable<T>
|
onErrorReturn(Function<? super Throwable, ? extends T> valueSupplier)
Instructs an ObservableSource to emit an item (returned by a specified function) rather than invoking
onError if it encounters an error.
|
final
Observable<T>
|
onErrorReturnItem(T item)
Instructs an ObservableSource to emit an item (returned by a specified function) rather than invoking
onError if it encounters an error.
|
final
Observable<T>
|
onExceptionResumeNext(ObservableSource<? extends T> next)
Instructs an ObservableSource to pass control to another ObservableSource rather than invoking
onError if it encounters an Exception .
|
final
Observable<T>
|
onTerminateDetach()
Nulls out references to the upstream producer and downstream Observer if
the sequence is terminated or downstream calls dispose().
|
final
ConnectableObservable<T>
|
publish()
Returns a ConnectableObservable , which is a variety of ObservableSource that waits until its
connect method is called before it begins emitting items to those
Observer s that have subscribed to it.
|
final
<R>
Observable<R>
|
publish(Function<? super Observable<T>, ? extends ObservableSource<R>> selector)
Returns an Observable that emits the results of invoking a specified selector on items emitted by a
ConnectableObservable that shares a single subscription to the underlying sequence.
|
static
Observable<Integer>
|
range(int start, int count)
Returns an Observable that emits a sequence of Integers within a specified range.
|
static
Observable<Long>
|
rangeLong(long start, long count)
Returns an Observable that emits a sequence of Longs within a specified range.
|
final
Maybe<T>
|
reduce(BiFunction<T, T, T> reducer)
Returns a Maybe that applies a specified accumulator function to the first item emitted by a source
ObservableSource, then feeds the result of that function along with the second item emitted by the source
ObservableSource into the same function, and so on until all items have been emitted by the source ObservableSource,
and emits the final result from the final call to your function as its sole item.
|
final
<R>
Single<R>
|
reduce(R seed, BiFunction<R, ? super T, R> reducer)
Returns a Single that applies a specified accumulator function to the first item emitted by a source
ObservableSource and a specified seed value, then feeds the result of that function along with the second item
emitted by an ObservableSource into the same function, and so on until all items have been emitted by the
source ObservableSource, emitting the final result from the final call to your function as its sole item.
|
final
<R>
Single<R>
|
reduceWith(Callable<R> seedSupplier, BiFunction<R, ? super T, R> reducer)
Returns a Single that applies a specified accumulator function to the first item emitted by a source
ObservableSource and a seed value derived from calling a specified seedSupplier, then feeds the result
of that function along with the second item emitted by an ObservableSource into the same function,
and so on until all items have been emitted by the source ObservableSource, emitting the final result
from the final call to your function as its sole item.
|
final
Observable<T>
|
repeat()
Returns an Observable that repeats the sequence of items emitted by the source ObservableSource indefinitely.
|
final
Observable<T>
|
repeat(long times)
Returns an Observable that repeats the sequence of items emitted by the source ObservableSource at most
count times.
|
final
Observable<T>
|
repeatUntil(BooleanSupplier stop)
Returns an Observable that repeats the sequence of items emitted by the source ObservableSource until
the provided stop function returns true.
|
final
Observable<T>
|
repeatWhen(Function<? super Observable<Object>, ? extends ObservableSource<?>> handler)
Returns an Observable that emits the same values as the source ObservableSource with the exception of an
onComplete .
|
final
<R>
Observable<R>
|
replay(Function<? super Observable<T>, ? extends ObservableSource<R>> selector, int bufferSize, Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying a maximum of bufferSize items.
|
final
<R>
Observable<R>
|
replay(Function<? super Observable<T>, ? extends ObservableSource<R>> selector, int bufferSize)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying bufferSize notifications.
|
final
<R>
Observable<R>
|
replay(Function<? super Observable<T>, ? extends ObservableSource<R>> selector, int bufferSize, long time, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying no more than bufferSize items that were emitted within a specified time window.
|
final
ConnectableObservable<T>
|
replay(int bufferSize, long time, TimeUnit unit)
Returns a ConnectableObservable that shares a single subscription to the source ObservableSource and
replays at most bufferSize items that were emitted during a specified time window.
|
final
ConnectableObservable<T>
|
replay(int bufferSize, long time, TimeUnit unit, Scheduler scheduler)
Returns a ConnectableObservable that shares a single subscription to the source ObservableSource and
that replays a maximum of bufferSize items that are emitted within a specified time window.
|
final
ConnectableObservable<T>
|
replay(int bufferSize)
Returns a ConnectableObservable that shares a single subscription to the source ObservableSource that
replays at most bufferSize items emitted by that ObservableSource.
|
final
ConnectableObservable<T>
|
replay()
Returns a ConnectableObservable that shares a single subscription to the underlying ObservableSource
that will replay all of its items and notifications to any future Observer .
|
final
<R>
Observable<R>
|
replay(Function<? super Observable<T>, ? extends ObservableSource<R>> selector, int bufferSize, long time, TimeUnit unit)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying no more than bufferSize items that were emitted within a specified time window.
|
final
ConnectableObservable<T>
|
replay(long time, TimeUnit unit)
Returns a ConnectableObservable that shares a single subscription to the source ObservableSource and
replays all items emitted by that ObservableSource within a specified time window.
|
final
<R>
Observable<R>
|
replay(Function<? super Observable<T>, ? extends ObservableSource<R>> selector)
Returns an Observable that emits items that are the results of invoking a specified selector on the items
emitted by a ConnectableObservable that shares a single subscription to the source ObservableSource.
|
final
<R>
Observable<R>
|
replay(Function<? super Observable<T>, ? extends ObservableSource<R>> selector, Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the source ObservableSource.
|
final
ConnectableObservable<T>
|
replay(Scheduler scheduler)
Returns a ConnectableObservable that shares a single subscription to the source ObservableSource that
will replay all of its items and notifications to any future Observer on the given
Scheduler .
|
final
ConnectableObservable<T>
|
replay(int bufferSize, Scheduler scheduler)
Returns a ConnectableObservable that shares a single subscription to the source ObservableSource and
replays at most bufferSize items emitted by that ObservableSource.
|
final
<R>
Observable<R>
|
replay(Function<? super Observable<T>, ? extends ObservableSource<R>> selector, long time, TimeUnit unit)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying all items that were emitted within a specified time window.
|
final
<R>
Observable<R>
|
replay(Function<? super Observable<T>, ? extends ObservableSource<R>> selector, long time, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying all items that were emitted within a specified time window.
|
final
ConnectableObservable<T>
|
replay(long time, TimeUnit unit, Scheduler scheduler)
Returns a ConnectableObservable that shares a single subscription to the source ObservableSource and
replays all items emitted by that ObservableSource within a specified time window.
|
final
Observable<T>
|
retry()
Returns an Observable that mirrors the source ObservableSource, resubscribing to it if it calls onError
(infinite retry count).
|
final
Observable<T>
|
retry(long times)
Returns an Observable that mirrors the source ObservableSource, resubscribing to it if it calls onError
up to a specified number of retries.
|
final
Observable<T>
|
retry(long times, Predicate<? super Throwable> predicate)
Retries at most times or until the predicate returns false, whichever happens first.
|
final
Observable<T>
|
retry(BiPredicate<? super Integer, ? super Throwable> predicate)
Returns an Observable that mirrors the source ObservableSource, resubscribing to it if it calls onError
and the predicate returns true for that specific exception and retry count.
|
final
Observable<T>
|
retry(Predicate<? super Throwable> predicate)
Retries the current Observable if the predicate returns true.
|
final
Observable<T>
|
retryUntil(BooleanSupplier stop)
Retries until the given stop function returns true.
|
final
Observable<T>
|
retryWhen(Function<? super Observable<Throwable>, ? extends ObservableSource<?>> handler)
Returns an Observable that emits the same values as the source ObservableSource with the exception of an
onError .
|
final
void
|
safeSubscribe(Observer<? super T> s)
Subscribes to the current Observable and wraps the given Observer into a SafeObserver
(if not already a SafeObserver) that
deals with exceptions thrown by a misbehaving Observer (that doesn't follow the
Reactive-Streams specification).
|
final
Observable<T>
|
sample(long period, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits the most recently emitted item (if any) emitted by the source ObservableSource
within periodic time intervals, where the intervals are defined on a particular Scheduler.
|
final
Observable<T>
|
sample(long period, TimeUnit unit)
Returns an Observable that emits the most recently emitted item (if any) emitted by the source ObservableSource
within periodic time intervals.
|
final
<U>
Observable<T>
|
sample(ObservableSource<U> sampler)
Returns an Observable that, when the specified sampler ObservableSource emits an item or completes,
emits the most recently emitted item (if any) emitted by the source ObservableSource since the previous
emission from the sampler ObservableSource.
|
final
Observable<T>
|
sample(long period, TimeUnit unit, boolean emitLast)
Returns an Observable that emits the most recently emitted item (if any) emitted by the source ObservableSource
within periodic time intervals and optionally emit the very last upstream item when the upstream completes.
|
final
Observable<T>
|
sample(long period, TimeUnit unit, Scheduler scheduler, boolean emitLast)
Returns an Observable that emits the most recently emitted item (if any) emitted by the source ObservableSource
within periodic time intervals, where the intervals are defined on a particular Scheduler
and optionally emit the very last upstream item when the upstream completes.
|
final
<U>
Observable<T>
|
sample(ObservableSource<U> sampler, boolean emitLast)
Returns an Observable that, when the specified sampler ObservableSource emits an item or completes,
emits the most recently emitted item (if any) emitted by the source ObservableSource since the previous
emission from the sampler ObservableSource
and optionally emit the very last upstream item when the upstream or other ObservableSource complete.
|
final
<R>
Observable<R>
|
scan(R initialValue, BiFunction<R, ? super T, R> accumulator)
Returns an Observable that applies a specified accumulator function to the first item emitted by a source
ObservableSource and a seed value, then feeds the result of that function along with the second item emitted by
the source ObservableSource into the same function, and so on until all items have been emitted by the source
ObservableSource, emitting the result of each of these iterations.
|
final
Observable<T>
|
scan(BiFunction<T, T, T> accumulator)
Returns an Observable that applies a specified accumulator function to the first item emitted by a source
ObservableSource, then feeds the result of that function along with the second item emitted by the source
ObservableSource into the same function, and so on until all items have been emitted by the source ObservableSource,
emitting the result of each of these iterations.
|
final
<R>
Observable<R>
|
scanWith(Callable<R> seedSupplier, BiFunction<R, ? super T, R> accumulator)
Returns an Observable that applies a specified accumulator function to the first item emitted by a source
ObservableSource and a seed value, then feeds the result of that function along with the second item emitted by
the source ObservableSource into the same function, and so on until all items have been emitted by the source
ObservableSource, emitting the result of each of these iterations.
|
static
<T>
Single<Boolean>
|
sequenceEqual(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, int bufferSize)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise.
|
static
<T>
Single<Boolean>
|
sequenceEqual(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, BiPredicate<? super T, ? super T> isEqual, int bufferSize)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified
equality function.
|
static
<T>
Single<Boolean>
|
sequenceEqual(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2, BiPredicate<? super T, ? super T> isEqual)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified
equality function.
|
static
<T>
Single<Boolean>
|
sequenceEqual(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise.
|
final
Observable<T>
|
serialize()
|
final
Observable<T>
|
share()
|
final
Single<T>
|
single(T defaultItem)
Returns a Single that emits the single item emitted by this Observable, if this Observable
emits only a single item, or a default item if the source ObservableSource emits no items.
|
final
Maybe<T>
|
singleElement()
Returns a Maybe that emits the single item emitted by this Observable if this Observable
emits only a single item, otherwise if this Observable emits more than one item or no items, an
IllegalArgumentException or NoSuchElementException is signalled respectively.
|
final
Single<T>
|
singleOrError()
Returns a Single that emits the single item emitted by this Observable if this Observable
emits only a single item, otherwise
if this Observable completes without emitting any items or emits more than one item a
NoSuchElementException or IllegalArgumentException will be signalled respectively.
|
final
Observable<T>
|
skip(long count)
Returns an Observable that skips the first count items emitted by the source ObservableSource and emits
the remainder.
|
final
Observable<T>
|
skip(long time, TimeUnit unit, Scheduler scheduler)
Returns an Observable that skips values emitted by the source ObservableSource before a specified time window
on a specified Scheduler elapses.
|
final
Observable<T>
|
skip(long time, TimeUnit unit)
Returns an Observable that skips values emitted by the source ObservableSource before a specified time window
elapses.
|
final
Observable<T>
|
skipLast(int count)
Returns an Observable that drops a specified number of items from the end of the sequence emitted by the
source ObservableSource.
|
final
Observable<T>
|
skipLast(long time, TimeUnit unit)
Returns an Observable that drops items emitted by the source ObservableSource during a specified time window
before the source completes.
|
final
Observable<T>
|
skipLast(long time, TimeUnit unit, boolean delayError)
Returns an Observable that drops items emitted by the source ObservableSource during a specified time window
before the source completes.
|
final
Observable<T>
|
skipLast(long time, TimeUnit unit, Scheduler scheduler)
Returns an Observable that drops items emitted by the source ObservableSource during a specified time window
(defined on a specified scheduler) before the source completes.
|
final
Observable<T>
|
skipLast(long time, TimeUnit unit, Scheduler scheduler, boolean delayError, int bufferSize)
Returns an Observable that drops items emitted by the source ObservableSource during a specified time window
(defined on a specified scheduler) before the source completes.
|
final
Observable<T>
|
skipLast(long time, TimeUnit unit, Scheduler scheduler, boolean delayError)
Returns an Observable that drops items emitted by the source ObservableSource during a specified time window
(defined on a specified scheduler) before the source completes.
|
final
<U>
Observable<T>
|
skipUntil(ObservableSource<U> other)
Returns an Observable that skips items emitted by the source ObservableSource until a second ObservableSource emits
an item.
|
final
Observable<T>
|
skipWhile(Predicate<? super T> predicate)
Returns an Observable that skips all items emitted by the source ObservableSource as long as a specified
condition holds true, but emits all further source items as soon as the condition becomes false.
|
final
Observable<T>
|
sorted()
Returns an Observable that emits the events emitted by source ObservableSource, in a
sorted order.
|
final
Observable<T>
|
sorted(Comparator<? super T> sortFunction)
Returns an Observable that emits the events emitted by source ObservableSource, in a
sorted order based on a specified comparison function.
|
final
Observable<T>
|
startWith(ObservableSource<? extends T> other)
Returns an Observable that emits the items in a specified ObservableSource before it begins to emit
items emitted by the source ObservableSource.
|
final
Observable<T>
|
startWith(Iterable<? extends T> items)
Returns an Observable that emits the items in a specified Iterable before it begins to emit items
emitted by the source ObservableSource.
|
final
Observable<T>
|
startWith(T item)
Returns an Observable that emits a specified item before it begins to emit items emitted by the source
ObservableSource.
|
final
Observable<T>
|
startWithArray(T... items)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
ObservableSource.
|
final
Disposable
|
subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe)
Subscribes to an ObservableSource and provides callbacks to handle the items it emits and any error or
completion notification it issues.
|
final
void
|
subscribe(Observer<? super T> observer)
Subscribes the given Observer to this ObservableSource instance.
|
final
Disposable
|
subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)
Subscribes to an ObservableSource and provides callbacks to handle the items it emits and any error or
completion notification it issues.
|
final
Disposable
|
subscribe()
Subscribes to an ObservableSource and ignores onNext and onComplete emissions.
|
final
Disposable
|
subscribe(Consumer<? super T> onNext)
Subscribes to an ObservableSource and provides a callback to handle the items it emits.
|
final
Disposable
|
subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError)
Subscribes to an ObservableSource and provides callbacks to handle the items it emits and any error
notification it issues.
|
abstract
void
|
subscribeActual(Observer<? super T> observer)
Operator implementations (both source and intermediate) should implement this method that
performs the necessary business logic.
|
final
Observable<T>
|
subscribeOn(Scheduler scheduler)
Asynchronously subscribes Observers to this ObservableSource on the specified Scheduler .
|
final
<E extends Observer<? super T>>
E
|
subscribeWith(E observer)
Subscribes a given Observer (subclass) to this Observable and returns the given
Observer as is.
|
final
Observable<T>
|
switchIfEmpty(ObservableSource<? extends T> other)
Returns an Observable that emits the items emitted by the source ObservableSource or the items of an alternate
ObservableSource if the source ObservableSource is empty.
|
final
<R>
Observable<R>
|
switchMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources.
|
final
<R>
Observable<R>
|
switchMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources.
|
final
<R>
Observable<R>
|
switchMapDelayError(Function<? super T, ? extends ObservableSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources and delays any error until all ObservableSources terminate.
|
final
<R>
Observable<R>
|
switchMapDelayError(Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources and delays any error until all ObservableSources terminate.
|
final
<R>
Observable<R>
|
switchMapSingle(Function<? super T, ? extends SingleSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns a SingleSource, and then emitting the item emitted by the most recently emitted
of these SingleSources.
|
final
<R>
Observable<R>
|
switchMapSingleDelayError(Function<? super T, ? extends SingleSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns a SingleSource, and then emitting the item emitted by the most recently emitted
of these SingleSources and delays any error until all SingleSources terminate.
|
static
<T>
Observable<T>
|
switchOnNext(ObservableSource<? extends ObservableSource<? extends T>> sources, int bufferSize)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources.
|
static
<T>
Observable<T>
|
switchOnNext(ObservableSource<? extends ObservableSource<? extends T>> sources)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources.
|
static
<T>
Observable<T>
|
switchOnNextDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources, int prefetch)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources and delays any exception until all ObservableSources terminate.
|
static
<T>
Observable<T>
|
switchOnNextDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources and delays any exception until all ObservableSources terminate.
|
final
Observable<T>
|
take(long time, TimeUnit unit)
Returns an Observable that emits those items emitted by source ObservableSource before a specified time runs
out.
|
final
Observable<T>
|
take(long time, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits those items emitted by source ObservableSource before a specified time (on a
specified Scheduler) runs out.
|
final
Observable<T>
|
take(long count)
Returns an Observable that emits only the first count items emitted by the source ObservableSource.
|
final
Observable<T>
|
takeLast(long time, TimeUnit unit, boolean delayError)
Returns an Observable that emits the items from the source ObservableSource that were emitted in a specified
window of time before the ObservableSource completed.
|
final
Observable<T>
|
takeLast(long count, long time, TimeUnit unit, Scheduler scheduler, boolean delayError, int bufferSize)
Returns an Observable that emits at most a specified number of items from the source ObservableSource that were
emitted in a specified window of time before the ObservableSource completed, where the timing information is
provided by a given Scheduler.
|
final
Observable<T>
|
takeLast(long time, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits the items from the source ObservableSource that were emitted in a specified
window of time before the ObservableSource completed, where the timing information is provided by a specified
Scheduler.
|
final
Observable<T>
|
takeLast(long time, TimeUnit unit, Scheduler scheduler, boolean delayError)
Returns an Observable that emits the items from the source ObservableSource that were emitted in a specified
window of time before the ObservableSource completed, where the timing information is provided by a specified
Scheduler.
|
final
Observable<T>
|
takeLast(int count)
Returns an Observable that emits at most the last count items emitted by the source ObservableSource.
|
final
Observable<T>
|
takeLast(long time, TimeUnit unit)
Returns an Observable that emits the items from the source ObservableSource that were emitted in a specified
window of time before the ObservableSource completed.
|
final
Observable<T>
|
takeLast(long count, long time, TimeUnit unit)
Returns an Observable that emits at most a specified number of items from the source ObservableSource that were
emitted in a specified window of time before the ObservableSource completed.
|
final
Observable<T>
|
takeLast(long count, long time, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits at most a specified number of items from the source ObservableSource that were
emitted in a specified window of time before the ObservableSource completed, where the timing information is
provided by a given Scheduler.
|
final
Observable<T>
|
takeLast(long time, TimeUnit unit, Scheduler scheduler, boolean delayError, int bufferSize)
Returns an Observable that emits the items from the source ObservableSource that were emitted in a specified
window of time before the ObservableSource completed, where the timing information is provided by a specified
Scheduler.
|
final
Observable<T>
|
takeUntil(Predicate<? super T> stopPredicate)
Returns an Observable that emits items emitted by the source Observable, checks the specified predicate
for each item, and then completes when the condition is satisfied.
|
final
<U>
Observable<T>
|
takeUntil(ObservableSource<U> other)
Returns an Observable that emits the items emitted by the source Observable until a second ObservableSource
emits an item.
|
final
Observable<T>
|
takeWhile(Predicate<? super T> predicate)
Returns an Observable that emits items emitted by the source ObservableSource so long as each item satisfied a
specified condition, and then completes as soon as this condition is not satisfied.
|
final
TestObserver<T>
|
test(boolean dispose)
Creates a TestObserver, optionally disposes it and then subscribes
it to this Observable.
|
final
TestObserver<T>
|
test()
Creates a TestObserver and subscribes
it to this Observable.
|
final
Observable<T>
|
throttleFirst(long windowDuration, TimeUnit unit)
Returns an Observable that emits only the first item emitted by the source ObservableSource during sequential
time windows of a specified duration.
|
final
Observable<T>
|
throttleFirst(long skipDuration, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits only the first item emitted by the source ObservableSource during sequential
time windows of a specified duration, where the windows are managed by a specified Scheduler.
|
final
Observable<T>
|
throttleLast(long intervalDuration, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits only the last item emitted by the source ObservableSource during sequential
time windows of a specified duration, where the duration is governed by a specified Scheduler.
|
final
Observable<T>
|
throttleLast(long intervalDuration, TimeUnit unit)
Returns an Observable that emits only the last item emitted by the source ObservableSource during sequential
time windows of a specified duration.
|
final
Observable<T>
|
throttleWithTimeout(long timeout, TimeUnit unit, Scheduler scheduler)
Returns an Observable that only emits those items emitted by the source ObservableSource that are not followed
by another emitted item within a specified time window, where the time window is governed by a specified
Scheduler.
|
final
Observable<T>
|
throttleWithTimeout(long timeout, TimeUnit unit)
Returns an Observable that only emits those items emitted by the source ObservableSource that are not followed
by another emitted item within a specified time window.
|
final
Observable<Timed<T>>
|
timeInterval(Scheduler scheduler)
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source ObservableSource, where this interval is computed on a specified Scheduler.
|
final
Observable<Timed<T>>
|
timeInterval(TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source ObservableSource, where this interval is computed on a specified Scheduler.
|
final
Observable<Timed<T>>
|
timeInterval()
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source ObservableSource.
|
final
Observable<Timed<T>>
|
timeInterval(TimeUnit unit)
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source ObservableSource.
|
final
<V>
Observable<T>
|
timeout(Function<? super T, ? extends ObservableSource<V>> itemTimeoutIndicator, ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but that switches to a fallback ObservableSource if
an item emitted by the source ObservableSource doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an ObservableSource that is a function of the previous
item.
|
final
Observable<T>
|
timeout(long timeout, TimeUnit timeUnit, Scheduler scheduler, ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource but applies a timeout policy for each emitted
item using a specified Scheduler.
|
final
<U, V>
Observable<T>
|
timeout(ObservableSource<U> firstTimeoutIndicator, Function<? super T, ? extends ObservableSource<V>> itemTimeoutIndicator, ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but switches to a fallback ObservableSource if either
the first item emitted by the source ObservableSource or any subsequent item doesn't arrive within time windows
defined by other ObservableSources.
|
final
Observable<T>
|
timeout(long timeout, TimeUnit timeUnit)
Returns an Observable that mirrors the source ObservableSource but applies a timeout policy for each emitted
item.
|
final
Observable<T>
|
timeout(long timeout, TimeUnit timeUnit, ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource but applies a timeout policy for each emitted
item.
|
final
<U, V>
Observable<T>
|
timeout(ObservableSource<U> firstTimeoutIndicator, Function<? super T, ? extends ObservableSource<V>> itemTimeoutIndicator)
Returns an Observable that mirrors the source ObservableSource, but notifies observers of a
TimeoutException if either the first item emitted by the source ObservableSource or any subsequent item
doesn't arrive within time windows defined by other ObservableSources.
|
final
Observable<T>
|
timeout(long timeout, TimeUnit timeUnit, Scheduler scheduler)
Returns an Observable that mirrors the source ObservableSource but applies a timeout policy for each emitted
item, where this policy is governed on a specified Scheduler.
|
final
<V>
Observable<T>
|
timeout(Function<? super T, ? extends ObservableSource<V>> itemTimeoutIndicator)
Returns an Observable that mirrors the source ObservableSource, but notifies observers of a
TimeoutException if an item emitted by the source ObservableSource doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by an ObservableSource that
is a function of the previous item.
|
static
Observable<Long>
|
timer(long delay, TimeUnit unit)
Returns an Observable that emits 0L after a specified delay, and then completes.
|
static
Observable<Long>
|
timer(long delay, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits 0L after a specified delay, on a specified Scheduler, and then
completes.
|
final
Observable<Timed<T>>
|
timestamp(TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits each item emitted by the source ObservableSource, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler.
|
final
Observable<Timed<T>>
|
timestamp()
Returns an Observable that emits each item emitted by the source ObservableSource, wrapped in a
Timed object.
|
final
Observable<Timed<T>>
|
timestamp(Scheduler scheduler)
Returns an Observable that emits each item emitted by the source ObservableSource, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler.
|
final
Observable<Timed<T>>
|
timestamp(TimeUnit unit)
Returns an Observable that emits each item emitted by the source ObservableSource, wrapped in a
Timed object.
|
final
<R>
R
|
to(Function<? super Observable<T>, R> converter)
Calls the specified converter function during assembly time and returns its resulting value.
|
final
Flowable<T>
|
toFlowable(BackpressureStrategy strategy)
Converts the current Observable into a Flowable by applying the specified backpressure strategy.
|
final
Future<T>
|
toFuture()
Returns a Future representing the single value emitted by this Observable .
|
final
<U extends Collection<? super T>>
Single<U>
|
toList(Callable<U> collectionSupplier)
Returns a Single that emits a single item, a list composed of all the items emitted by the
finite source ObservableSource.
|
final
Single<List<T>>
|
toList()
Returns a Single that emits a single item, a list composed of all the items emitted by the
finite source ObservableSource.
|
final
Single<List<T>>
|
toList(int capacityHint)
Returns a Single that emits a single item, a list composed of all the items emitted by the
finite source ObservableSource.
|
final
<K>
Single<Map<K, T>>
|
toMap(Function<? super T, ? extends K> keySelector)
Returns a Single that emits a single HashMap containing all items emitted by the source ObservableSource,
mapped by the keys returned by a specified keySelector function.
|
final
<K, V>
Single<Map<K, V>>
|
toMap(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, Callable<? extends Map<K, V>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified mapFactory function, that
contains keys and values extracted from the items emitted by the source ObservableSource.
|
final
<K, V>
Single<Map<K, V>>
|
toMap(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector)
Returns a Single that emits a single HashMap containing values corresponding to items emitted by the
source ObservableSource, mapped by the keys returned by a specified keySelector function.
|
final
<K>
Single<Map<K, Collection<T>>>
|
toMultimap(Function<? super T, ? extends K> keySelector)
Returns a Single that emits a single HashMap that contains an ArrayList of items emitted by the
source ObservableSource keyed by a specified keySelector function.
|
final
<K, V>
Single<Map<K, Collection<V>>>
|
toMultimap(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, Callable<Map<K, Collection<V>>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the source ObservableSource and keyed by the keySelector function.
|
final
<K, V>
Single<Map<K, Collection<V>>>
|
toMultimap(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector)
Returns a Single that emits a single HashMap that contains an ArrayList of values extracted by a
specified valueSelector function from items emitted by the source ObservableSource, keyed by a
specified keySelector function.
|
final
<K, V>
Single<Map<K, Collection<V>>>
|
toMultimap(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, Callable<? extends Map<K, Collection<V>>> mapSupplier, Function<? super K, ? extends Collection<? super V>> collectionFactory)
Returns a Single that emits a single Map, returned by a specified mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the source ObservableSource, and keyed by the keySelector function.
|
final
Single<List<T>>
|
toSortedList(Comparator<? super T> comparator, int capacityHint)
Returns a Single that emits a list that contains the items emitted by the source ObservableSource, in a
sorted order based on a specified comparison function.
|
final
Single<List<T>>
|
toSortedList(Comparator<? super T> comparator)
Returns a Single that emits a list that contains the items emitted by the source ObservableSource, in a
sorted order based on a specified comparison function.
|
final
Single<List<T>>
|
toSortedList()
Returns a Single that emits a list that contains the items emitted by the source ObservableSource, in a
sorted order.
|
final
Single<List<T>>
|
toSortedList(int capacityHint)
Returns a Single that emits a list that contains the items emitted by the source ObservableSource, in a
sorted order.
|
static
<T>
Observable<T>
|
unsafeCreate(ObservableSource<T> onSubscribe)
Create an Observable by wrapping an ObservableSource which has to be implemented according
to the Reactive-Streams-based Observable specification by handling
cancellation correctly; no safeguards are provided by the Observable itself.
|
final
Observable<T>
|
unsubscribeOn(Scheduler scheduler)
Modifies the source ObservableSource so that subscribers will dispose it on a specified
Scheduler .
|
static
<T, D>
Observable<T>
|
using(Callable<? extends D> resourceSupplier, Function<? super D, ? extends ObservableSource<? extends T>> sourceSupplier, Consumer<? super D> disposer, boolean eager)
Constructs an ObservableSource that creates a dependent resource object which is disposed of just before
termination if you have set disposeEagerly to true and a dispose() call does not occur
before termination.
|
static
<T, D>
Observable<T>
|
using(Callable<? extends D> resourceSupplier, Function<? super D, ? extends ObservableSource<? extends T>> sourceSupplier, Consumer<? super D> disposer)
Constructs an ObservableSource that creates a dependent resource object which is disposed of when the downstream
calls dispose().
|
final
<B>
Observable<Observable<T>>
|
window(Callable<? extends ObservableSource<B>> boundary)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, long timeskip, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, TimeUnit unit, Scheduler scheduler, long count, boolean restart)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
<B>
Observable<Observable<T>>
|
window(ObservableSource<B> boundary)
Returns an Observable that emits non-overlapping windows of items it collects from the source ObservableSource
where the boundary of each window is determined by the items emitted from a specified boundary-governing
ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, TimeUnit unit, Scheduler scheduler, long count, boolean restart, int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, TimeUnit unit, Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
<B>
Observable<Observable<T>>
|
window(ObservableSource<B> boundary, int bufferSize)
Returns an Observable that emits non-overlapping windows of items it collects from the source ObservableSource
where the boundary of each window is determined by the items emitted from a specified boundary-governing
ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
<B>
Observable<Observable<T>>
|
window(Callable<? extends ObservableSource<B>> boundary, int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long count)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long count, long skip)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
<U, V>
Observable<Observable<T>>
|
window(ObservableSource<U> openingIndicator, Function<? super U, ? extends ObservableSource<V>> closingIndicator)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, long timeskip, TimeUnit unit)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
<U, V>
Observable<Observable<T>>
|
window(ObservableSource<U> openingIndicator, Function<? super U, ? extends ObservableSource<V>> closingIndicator, int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, TimeUnit unit, long count)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, TimeUnit unit, long count, boolean restart)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, TimeUnit unit, Scheduler scheduler, long count)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long timespan, TimeUnit unit)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
Observable<Observable<T>>
|
window(long count, long skip, int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
final
<R>
Observable<R>
|
withLatestFrom(Iterable<? extends ObservableSource<?>> others, Function<? super Object[], R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
final
<T1, T2, R>
Observable<R>
|
withLatestFrom(ObservableSource<T1> o1, ObservableSource<T2> o2, Function3<? super T, ? super T1, ? super T2, R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
final
<T1, T2, T3, T4, R>
Observable<R>
|
withLatestFrom(ObservableSource<T1> o1, ObservableSource<T2> o2, ObservableSource<T3> o3, ObservableSource<T4> o4, Function5<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
final
<U, R>
Observable<R>
|
withLatestFrom(ObservableSource<? extends U> other, BiFunction<? super T, ? super U, ? extends R> combiner)
Merges the specified ObservableSource into this ObservableSource sequence by using the resultSelector
function only when the source ObservableSource (this instance) emits an item.
|
final
<T1, T2, T3, R>
Observable<R>
|
withLatestFrom(ObservableSource<T1> o1, ObservableSource<T2> o2, ObservableSource<T3> o3, Function4<? super T, ? super T1, ? super T2, ? super T3, R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
final
<R>
Observable<R>
|
withLatestFrom(ObservableSource[]<?> others, Function<? super Object[], R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
static
<T>
Observable<T>
|
wrap(ObservableSource<T> source)
Wraps an ObservableSource into an Observable if not already an Observable.
|
static
<T1, T2, T3, T4, T5, T6, T7, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, ObservableSource<? extends T6> source6, ObservableSource<? extends T7> source7, Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static
<T, R>
Observable<R>
|
zip(ObservableSource<? extends ObservableSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the n ObservableSources emitted by a specified ObservableSource.
|
static
<T1, T2, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, BiFunction<? super T1, ? super T2, ? extends R> zipper, boolean delayError, int bufferSize)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static
<T1, T2, T3, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, Function3<? super T1, ? super T2, ? super T3, ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other ObservableSources.
|
static
<T1, T2, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, BiFunction<? super T1, ? super T2, ? extends R> zipper, boolean delayError)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static
<T, R>
Observable<R>
|
zip(Iterable<? extends ObservableSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other ObservableSources.
|
static
<T1, T2, T3, T4, T5, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other ObservableSources.
|
static
<T1, T2, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, BiFunction<? super T1, ? super T2, ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static
<T1, T2, T3, T4, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other ObservableSources.
|
static
<T1, T2, T3, T4, T5, T6, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, ObservableSource<? extends T6> source6, Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other ObservableSources.
|
static
<T1, T2, T3, T4, T5, T6, T7, T8, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, ObservableSource<? extends T6> source6, ObservableSource<? extends T7> source7, ObservableSource<? extends T8> source8, Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static
<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>
Observable<R>
|
zip(ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2, ObservableSource<? extends T3> source3, ObservableSource<? extends T4> source4, ObservableSource<? extends T5> source5, ObservableSource<? extends T6> source6, ObservableSource<? extends T7> source7, ObservableSource<? extends T8> source8, ObservableSource<? extends T9> source9, Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static
<T, R>
Observable<R>
|
zipArray(Function<? super Object[], ? extends R> zipper, boolean delayError, int bufferSize, ObservableSource...<? extends T> sources)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an array of other ObservableSources.
|
static
<T, R>
Observable<R>
|
zipIterable(Iterable<? extends ObservableSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper, boolean delayError, int bufferSize)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other ObservableSources.
|
final
<U, R>
Observable<R>
|
zipWith(ObservableSource<? extends U> other, BiFunction<? super T, ? super U, ? extends R> zipper)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source ObservableSource and another specified ObservableSource.
|
final
<U, R>
Observable<R>
|
zipWith(ObservableSource<? extends U> other, BiFunction<? super T, ? super U, ? extends R> zipper, boolean delayError)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source ObservableSource and another specified ObservableSource.
|
final
<U, R>
Observable<R>
|
zipWith(ObservableSource<? extends U> other, BiFunction<? super T, ? super U, ? extends R> zipper, boolean delayError, int bufferSize)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source ObservableSource and another specified ObservableSource.
|
final
<U, R>
Observable<R>
|
zipWith(Iterable<U> other, BiFunction<? super T, ? super U, ? extends R> zipper)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source ObservableSource and a specified Iterable sequence.
|