This class provides methods for subscribing to the Observable as well as delegate methods to the various Observers.
The documentation for this class makes use of marble diagrams. The following legend explains these diagrams:
For more information see the ReactiveX documentation.
| Modifier and Type | Class and Description |
|---|---|
| public static interface | |
| public static interface | Observable.Operator<
the downstream's value type (output) R, the upstream's value type (input) T>Operator function for lifting into an Observable. |
| public static interface | Observable.Transformer<
the input Observable's value type T, the output Observable's value type R>Function that receives the current Observable and should return another Observable, possibly with given element type, in exchange that will be subscribed to by the downstream operators and subscribers. |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Observable. |
| Access | Constructor and Description |
|---|---|
| protected | Observable(Observable.
OnSubscribe to be executed when subscribe(Subscriber) is calledCreates an Observable with a Function to execute when it is subscribed to. |
| Modifier and Type | Method and Description |
|---|---|
| public final Observable | Returns: an Observable that emitstrue if all items emitted by the source Observable satisfy the
predicate; otherwise, falsea function that evaluates an item and returns a Boolean predicate)Returns an Observable that emits a Boolean that indicates whether all of the items emitted by the source Observable satisfy a condition. |
| public static < the common element type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Iterable of Observable sources competing to react first sources)Mirrors the one Observable in an Iterable of several Observables that first either emits an item or sends a termination notification. |
| public static < the common element type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first o1, Observable<? extends T> an Observable competing to react first o2)Given two Observables, mirrors the one that first either emits an item or sends a termination notification. |
| public static < the common element base type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first o1, Observable<? extends T> an Observable competing to react first o2, Observable<? extends T> an Observable competing to react first o3)Given three Observables, mirrors the one that first either emits an item or sends a termination notification. |
| public static < the common element base type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first o1, Observable<? extends T> an Observable competing to react first o2, Observable<? extends T> an Observable competing to react first o3, Observable<? extends T> an Observable competing to react first o4)Given four Observables, mirrors the one that first either emits an item or sends a termination notification. |
| public static < the common element base type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first o1, Observable<? extends T> an Observable competing to react first o2, Observable<? extends T> an Observable competing to react first o3, Observable<? extends T> an Observable competing to react first o4, Observable<? extends T> an Observable competing to react first o5)Given five Observables, mirrors the one that first either emits an item or sends a termination notification. |
| public static < the common element base type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first o1, Observable<? extends T> an Observable competing to react first o2, Observable<? extends T> an Observable competing to react first o3, Observable<? extends T> an Observable competing to react first o4, Observable<? extends T> an Observable competing to react first o5, Observable<? extends T> an Observable competing to react first o6)Given six Observables, mirrors the one that first either emits an item or sends a termination notification. |
| public static < the common element base type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first o1, Observable<? extends T> an Observable competing to react first o2, Observable<? extends T> an Observable competing to react first o3, Observable<? extends T> an Observable competing to react first o4, Observable<? extends T> an Observable competing to react first o5, Observable<? extends T> an Observable competing to react first o6, Observable<? extends T> an Observable competing to react first o7)Given seven Observables, mirrors the one that first either emits an item or sends a termination notification. |
| public static < the common element base type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first o1, Observable<? extends T> an Observable competing to react first o2, Observable<? extends T> an Observable competing to react first o3, Observable<? extends T> an Observable competing to react first o4, Observable<? extends T> an Observable competing to react first o5, Observable<? extends T> an Observable competing to react first o6, Observable<? extends T> an Observable competing to react first o7, Observable<? extends T> an observable competing to react first o8)Given eight Observables, mirrors the one that first either emits an item or sends a termination notification. |
| public static < the common element base type T> Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first o1, Observable<? extends T> an Observable competing to react first o2, Observable<? extends T> an Observable competing to react first o3, Observable<? extends T> an Observable competing to react first o4, Observable<? extends T> an Observable competing to react first o5, Observable<? extends T> an Observable competing to react first o6, Observable<? extends T> an Observable competing to react first o7, Observable<? extends T> an Observable competing to react first o8, Observable<? extends T> an Observable competing to react first o9)Given nine Observables, mirrors the one that first either emits an item or sends a termination notification. |
| public final Observable | Returns: an Observable that emits the same sequence as whichever of the source Observables first emitted an item or sent a termination notificationan Observable competing to react first t1)Mirrors the Observable (current or provided) that first either emits an item or sends a termination notification. |
| public final Observable | Returns: an Observable that hides the identity of this ObservablePortrays a object of an Observable subclass as a simple Observable object. |
| public final < the value type of the boundary-providing Observable TClosing> Observable | Returns: an Observable that emits a connected, non-overlapping buffer of items from the source Observable each time the Observable created with thebufferClosingSelector argument emits an itema bufferClosingSelector)Func0 that produces an Observable that governs the boundary between buffers.
Whenever the source Observable emits an item, buffer emits the current buffer and
begins to fill a new oneReturns an Observable that emits buffers of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping buffers, each containing at mostcount items from the source Observablethe maximum number of items in each buffer before it should be emitted count)Returns an Observable that emits buffers of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits buffers for everyskip item from the source Observable and
containing at most count itemsthe maximum size of each buffer before it should be emitted count, int how many items emitted by the source Observable should be skipped before starting a new
buffer. Note that when skip)skip and count are equal, this is the same operation as
buffer(int).Returns an Observable that emits buffers of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits new buffers of items emitted by the source Observable periodically after a fixed timespan has elapsedthe period of time each buffer collects items before it is emitted timespan, long the period of time after which a new buffer will be created timeshift, TimeUnit the unit of time that applies to the unit)timespan and timeshift argumentsReturns an Observable that emits buffers of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits new buffers of items emitted by the source Observable periodically after a fixed timespan has elapsedthe period of time each buffer collects items before it is emitted timespan, long the period of time after which a new buffer will be created timeshift, TimeUnit the unit of time that applies to the unit, Scheduler timespan and timeshift argumentsthe scheduler)Scheduler to use when determining the end and start of a bufferReturns an Observable that emits buffers of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping buffers of items emitted by the source Observable within a fixed durationthe period of time each buffer collects items before it is emitted and replaced with a new
buffer timespan, TimeUnit the unit of time that applies to the unit)timespan argumentReturns an Observable that emits buffers of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping buffers of items emitted by the source Observable, after a fixed duration or when the buffer reaches maximum capacity (whichever occurs first)the period of time each buffer collects items before it is emitted and replaced with a new
buffer timespan, TimeUnit the unit of time which applies to the unit, int timespan argumentthe maximum size of each buffer before it is emitted count)Returns an Observable that emits buffers of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping buffers of items emitted by the source Observable after a fixed duration or when the buffer reaches maximum capacity (whichever occurs first)the period of time each buffer collects items before it is emitted and replaced with a new
buffer timespan, TimeUnit the unit of time which applies to the unit, int timespan argumentthe maximum size of each buffer before it is emitted count, Scheduler the scheduler)Scheduler to use when determining the end and start of a bufferReturns an Observable that emits buffers of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping buffers of items emitted by the source Observable within a fixed durationthe period of time each buffer collects items before it is emitted and replaced with a new
buffer timespan, TimeUnit the unit of time which applies to the unit, Scheduler timespan argumentthe scheduler)Scheduler to use when determining the end and start of a bufferReturns an Observable that emits buffers of items it collects from the source Observable. |
| public final < the element type of the buffer-opening Observable TOpening, the element type of the individual buffer-closing Observables TClosing> Observable | Returns: an Observable that emits buffers, containing items from the source Observable, that are created and closed when the specified Observables emit itemsthe Observable that, when it emits an item, causes a new buffer to be created bufferOpenings, Func1<? super TOpening, ? extends Observable<? extends TClosing>> the bufferClosingSelector)Func1 that is used to produce an Observable for every buffer created. When this
Observable emits an item, the associated buffer is emitted.Returns an Observable that emits buffers of items it collects from the source Observable. |
| public final < the boundary value type (ignored) B> Observable | Returns: an Observable that emits buffered items from the source Observable when the boundary Observable emits an itemthe boundary Observable boundary)Returns an Observable that emits non-overlapping buffered items from the source Observable each time the specified boundary Observable emits an item. |
| public final < the boundary value type (ignored) B> Observable | Returns: an Observable that emits buffered items from the source Observable when the boundary Observable emits an itemthe boundary Observable boundary, int the initial capacity of each buffer chunk initialCapacity)Returns an Observable that emits non-overlapping buffered items from the source Observable each time the specified boundary Observable emits an item. |
| public final Observable | Returns: an Observable that, when first subscribed to, caches all of its items and notifications for the benefit of subsequent subscribersReturns an Observable that subscribes to this Observable lazily, caches all of its events and replays them, in the same order as received, to all the downstream subscribers. |
| public final Observable | Returns: the new Observable instance with the specific behavior.the capacity to start with initialCapacity)
Deprecated
Use
Caches and shares everything from this Observable and uses the initialCapacity to
reduce the number of times the internal buffer needs resizing.
cacheWithInitialCapacity(int) instead.
|
| public final Observable | Returns: an Observable that, when first subscribed to, caches all of its items and notifications for the benefit of subsequent subscribershint for number of items to cache (for optimizing underlying data structure) initialCapacity)Returns an Observable that subscribes to this Observable lazily, caches all of its events and replays them, in the same order as received, to all the downstream subscribers. |
| public final < the output value type cast to R> Observable | Returns: an Observable that emits each item from the source Observable after converting it to the specified typethe target class type that klass)cast will cast the items emitted by the source Observable
into before emitting them from the resulting ObservableReturns an Observable that emits the items emitted by the source Observable, converted to the specified type. |
| public final < the accumulator and output type R> Observable | Returns: an Observable that emits the result of collecting the values emitted by the source Observable into a single mutable data structurethe mutable data structure that will collect the items stateFactory, final Action2<R, ? super T> a function that accepts the collector)state and an emitted item, and modifies state
accordinglyCollects items emitted by the source Observable into a single mutable data structure and returns an Observable that emits this structure. |
| public static < the element type of the first source T1, the element type of the second source T2, the combined output type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe first source Observable o1, Observable<? extends T2> the second source Observable o2, Func2<? super T1, ? super T2, ? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines two source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from either of the source Observables, where this aggregation is defined by a specified function. |
| public static < the element type of the first source T1, the element type of the second source T2, the element type of the third source T3, the combined output type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe first source Observable o1, Observable<? extends T2> the second source Observable o2, Observable<? extends T3> the third source Observable o3, Func3<? super T1, ? super T2, ? super T3, ? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines three source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the element type of the first source T1, the element type of the second source T2, the element type of the third source T3, the element type of the fourth source T4, the combined output type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe first source Observable o1, Observable<? extends T2> the second source Observable o2, Observable<? extends T3> the third source Observable o3, Observable<? extends T4> the fourth source Observable o4, Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines four source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the element type of the first source T1, the element type of the second source T2, the element type of the third source T3, the element type of the fourth source T4, the element type of the fifth source T5, the combined output type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe first source Observable o1, Observable<? extends T2> the second source Observable o2, Observable<? extends T3> the third source Observable o3, Observable<? extends T4> the fourth source Observable o4, Observable<? extends T5> the fifth source Observable o5, Func5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines five source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the element type of the first source T1, the element type of the second source T2, the element type of the third source T3, the element type of the fourth source T4, the element type of the fifth source T5, the element type of the sixth source T6, the combined output type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe first source Observable o1, Observable<? extends T2> the second source Observable o2, Observable<? extends T3> the third source Observable o3, Observable<? extends T4> the fourth source Observable o4, Observable<? extends T5> the fifth source Observable o5, Observable<? extends T6> the sixth source Observable o6, Func6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines six source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the element type of the first source T1, the element type of the second source T2, the element type of the third source T3, the element type of the fourth source T4, the element type of the fifth source T5, the element type of the sixth source T6, the element type of the seventh source T7, the combined output type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe first source Observable o1, Observable<? extends T2> the second source Observable o2, Observable<? extends T3> the third source Observable o3, Observable<? extends T4> the fourth source Observable o4, Observable<? extends T5> the fifth source Observable o5, Observable<? extends T6> the sixth source Observable o6, Observable<? extends T7> the seventh source Observable o7, Func7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines seven source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the element type of the first source T1, the element type of the second source T2, the element type of the third source T3, the element type of the fourth source T4, the element type of the fifth source T5, the element type of the sixth source T6, the element type of the seventh source T7, the element type of the eighth source T8, the combined output type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe first source Observable o1, Observable<? extends T2> the second source Observable o2, Observable<? extends T3> the third source Observable o3, Observable<? extends T4> the fourth source Observable o4, Observable<? extends T5> the fifth source Observable o5, Observable<? extends T6> the sixth source Observable o6, Observable<? extends T7> the seventh source Observable o7, Observable<? extends T8> the eighth source Observable o8, Func8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines eight source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the element type of the first source T1, the element type of the second source T2, the element type of the third source T3, the element type of the fourth source T4, the element type of the fifth source T5, the element type of the sixth source T6, the element type of the seventh source T7, the element type of the eighth source T8, the element type of the ninth source T9, the combined output type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe first source Observable o1, Observable<? extends T2> the second source Observable o2, Observable<? extends T3> the third source Observable o3, Observable<? extends T4> the fourth source Observable o4, Observable<? extends T5> the fifth source Observable o5, Observable<? extends T6> the sixth source Observable o6, Observable<? extends T7> the seventh source Observable o7, Observable<? extends T8> the eighth source Observable o8, Observable<? extends T9> the ninth source Observable o9, Func9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines nine source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the common base type of source values T, the result type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe list of source Observables sources, FuncN<? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines a list of source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the common base type of source values T, the result type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe collection of source Observables sources, FuncN<? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines a collection of source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function. |
| public static < the common base type of source values T, the result type R> Observable | Returns: an Observable that emits items that are the result of combining the items emitted by the source Observables by means of the given aggregation functionthe collection of source Observables sources, FuncN<? extends R> the aggregation function used to combine the items emitted by the source Observables combineFunction)Combines a collection of source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function and delays any error from the sources until all source Observables terminate. |
| public < the value type of the output Observable R> Observable | Returns: the source Observable, transformed by the transformer functionimplements the function that transforms the source Observable transformerTransform an Observable by applying a particular Transformer function to it. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items that are the result of flattening the items emitted by the Observables in the Iterable, one after the other, without interleaving themthe Iterable of Observables sequences)Flattens an Iterable of Observables into one Observable, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items all of the items emitted by the Observables emitted byobservables, one after the other, without interleaving theman Observable that emits Observables observables)Returns an Observable that emits the items emitted by each of the Observables emitted by the source Observable, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items emitted by the two source Observables, one after the other, without interleaving theman Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2)Returns an Observable that emits the items emitted by two Observables, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items emitted by the three source Observables, one after the other, without interleaving theman Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3)Returns an Observable that emits the items emitted by three Observables, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items emitted by the four source Observables, one after the other, without interleaving theman Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4)Returns an Observable that emits the items emitted by four Observables, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items emitted by the five source Observables, one after the other, without interleaving theman Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5)Returns an Observable that emits the items emitted by five Observables, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items emitted by the six source Observables, one after the other, without interleaving theman Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5, Observable<? extends T> an Observable to be concatenated t6)Returns an Observable that emits the items emitted by six Observables, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items emitted by the seven source Observables, one after the other, without interleaving theman Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5, Observable<? extends T> an Observable to be concatenated t6, Observable<? extends T> an Observable to be concatenated t7)Returns an Observable that emits the items emitted by seven Observables, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items emitted by the eight source Observables, one after the other, without interleaving theman Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5, Observable<? extends T> an Observable to be concatenated t6, Observable<? extends T> an Observable to be concatenated t7, Observable<? extends T> an Observable to be concatenated t8)Returns an Observable that emits the items emitted by eight Observables, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items emitted by the nine source Observables, one after the other, without interleaving theman Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5, Observable<? extends T> an Observable to be concatenated t6, Observable<? extends T> an Observable to be concatenated t7, Observable<? extends T> an Observable to be concatenated t8, Observable<? extends T> an Observable to be concatenated t9)Returns an Observable that emits the items emitted by nine Observables, one after the other, without interleaving them. |
| public static < the common element base type T> Observable | Returns: the new Observable with the concatenating behaviorthe Observable sequence of Observables sources)Concatenates the Observable sequence of Observables into a single sequence by subscribing to each inner Observable, one after the other, one at a time and delays any errors till the all inner and the outer Observables terminate. |
| public static < the common element base type T> Observable | Returns: the new Observable with the concatenating behaviorthe Iterable sequence of Observables sources)Concatenates the Iterable sequence of Observables into a single sequence by subscribing to each Observable, one after the other, one at a time and delays any errors till the all inner Observables terminate. |
| public static < the common element base type T> Observable | Returns: an Observable with the concatenating behavioran Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2)Returns an Observable that emits the items emitted by two Observables, one after the other, without interleaving them, and delays any errors till all Observables terminate. |
| public static < the common element base type T> Observable | Returns: an Observable with the concatenating behavioran Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3)Returns an Observable that emits the items emitted by three Observables, one after the other, without interleaving them, and delays any errors till all Observables terminate. |
| public static < the common element base type T> Observable | Returns: an Observable with the concatenating behavioran Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4)Returns an Observable that emits the items emitted by four Observables, one after the other, without interleaving them, and delays any errors till all Observables terminate. |
| public static < the common element base type T> Observable | Returns: an Observable with the concatenating behavioran Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5)Returns an Observable that emits the items emitted by five Observables, one after the other, without interleaving them, and delays any errors till all Observables terminate. |
| public static < the common element base type T> Observable | Returns: an Observable with the concatenating behavioran Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5, Observable<? extends T> an Observable to be concatenated t6)Returns an Observable that emits the items emitted by six Observables, one after the other, without interleaving them, and delays any errors till all Observables terminate. |
| public static < the common element base type T> Observable | Returns: an Observable with the concatenating behavioran Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5, Observable<? extends T> an Observable to be concatenated t6, Observable<? extends T> an Observable to be concatenated t7)Returns an Observable that emits the items emitted by seven Observables, one after the other, without interleaving them, and delays any errors till all Observables terminate. |
| public static < the common element base type T> Observable | Returns: an Observable with the concatenating behavioran Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5, Observable<? extends T> an Observable to be concatenated t6, Observable<? extends T> an Observable to be concatenated t7, Observable<? extends T> an Observable to be concatenated t8)Returns an Observable that emits the items emitted by eight Observables, one after the other, without interleaving them, and delays any errors till all Observables terminate. |
| public static < the common element base type T> Observable | Returns: an Observable with the concatenating behavioran Observable to be concatenated t1, Observable<? extends T> an Observable to be concatenated t2, Observable<? extends T> an Observable to be concatenated t3, Observable<? extends T> an Observable to be concatenated t4, Observable<? extends T> an Observable to be concatenated t5, Observable<? extends T> an Observable to be concatenated t6, Observable<? extends T> an Observable to be concatenated t7, Observable<? extends T> an Observable to be concatenated t8, Observable<? extends T> an Observable to be concatenated t9)Returns an Observable that emits the items emitted by nine Observables, one after the other, without interleaving them, and delays any errors till all Observables terminate. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe first source o1, Observable<? extends T> the second source o2)Concatenates two source Observables eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe first source o1, Observable<? extends T> the second source o2, Observable<? extends T> the third source o3)Concatenates three sources eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe first source o1, Observable<? extends T> the second source o2, Observable<? extends T> the third source o3, Observable<? extends T> the fourth source o4)Concatenates four sources eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe first source o1, Observable<? extends T> the second source o2, Observable<? extends T> the third source o3, Observable<? extends T> the fourth source o4, Observable<? extends T> the fifth source o5)Concatenates five sources eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe first source o1, Observable<? extends T> the second source o2, Observable<? extends T> the third source o3, Observable<? extends T> the fourth source o4, Observable<? extends T> the fifth source o5, Observable<? extends T> the sixth source o6)Concatenates six sources eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe first source o1, Observable<? extends T> the second source o2, Observable<? extends T> the third source o3, Observable<? extends T> the fourth source o4, Observable<? extends T> the fifth source o5, Observable<? extends T> the sixth source o6, Observable<? extends T> the seventh source o7)Concatenates seven sources eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe first source o1, Observable<? extends T> the second source o2, Observable<? extends T> the third source o3, Observable<? extends T> the fourth source o4, Observable<? extends T> the fifth source o5, Observable<? extends T> the sixth source o6, Observable<? extends T> the seventh source o7, Observable<? extends T> the eighth source o8)Concatenates eight sources eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe first source o1, Observable<? extends T> the second source o2, Observable<? extends T> the third source o3, Observable<? extends T> the fourth source o4, Observable<? extends T> the fifth source o5, Observable<? extends T> the sixth source o6, Observable<? extends T> the seventh source o7, Observable<? extends T> the eighth source o8, Observable<? extends T> the ninth source o9)Concatenates nine sources eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviora sequence of Observables that need to be eagerly concatenated sources)Concatenates a sequence of Observables eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviora sequence of Observables that need to be eagerly concatenated sources, int hints about the number of expected source sequence values capacityHint)Concatenates a sequence of Observables eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviora sequence of Observables that need to be eagerly concatenated sources)Concatenates an Observable sequence of Observables eagerly into a single stream of values. |
| public static < the value type T> Observable | Returns: the new Observable instance with the specified concatenation behaviora sequence of Observables that need to be eagerly concatenated sources, int hints about the number of expected source sequence values capacityHint)Concatenates an Observable sequence of Observables eagerly into a single stream of values. |
| public final < the type of the inner Observable sources and thus the output type R> Observable | Returns: an Observable that emits the result of applying the transformation function to each item emitted by the source Observable and concatenating the Observables obtained from this transformationa function that, when applied to an item emitted by the source Observable, returns an
Observable func)Returns a new Observable that emits items resulting from applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then emitting the items that result from concatenating those resulting Observables. |
| public final < the result value type R> Observable | Returns: the new Observable instance with the concatenation behaviorthe function that maps the items of this Observable into the inner Observables. func)Maps each of the items into an Observable, 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 Observables till all of them terminate. |
| public final < the value type R> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe function that maps a sequence of values into a sequence of Observables that will be
eagerly concatenated mapper)Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable. |
| public final < the value type R> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe function that maps a sequence of values into a sequence of Observables that will be
eagerly concatenated mapper, int hints about the number of expected source sequence values capacityHint)Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable. |
| public final < the value type R> Observable | Returns: the new Observable instance with the specified concatenation behaviorthe function that maps a sequence of values into a sequence of Observables that will be
eagerly concatenated mapper, int hints about the number of expected source sequence values capacityHint, int the maximum number of concurrent subscribed observables maxConcurrent)Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable. |
| public final < the type of item emitted by the resulting Observable R> Observable | Returns: an Observable that emits the results of concatenating the items emitted by the source Observable with the values in the Iterables corresponding to those items, as generated bycollectionSelectora function that returns an Iterable sequence of values for when given an item emitted by the
source Observable collectionSelector)Returns an Observable that concatenate each item emitted by the source Observable with the values in an Iterable corresponding to that item that is generated by a selector. |
| public final Observable | Returns: an Observable that emits items emitted by the two source Observables, one after the other, without interleaving theman Observable to be concatenated after the current t1)Returns an Observable that emits the items emitted from the current Observable, then the next, one after the other, without interleaving them. |
| public final Observable | Returns: an Observable that emitstrue if the specified item is emitted by the source Observable,
or false if the source Observable completes without emitting that itemthe item to search for in the emissions from the source Observable element)Returns an Observable that emits a Boolean that indicates whether the source Observable emitted a specified item. |
| public final Observable | Returns: an Observable that emits a single item: the number of elements emitted by the source ObservableReturns an Observable that emits the count of the total number of items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits a single item: the number of items emitted by the source Observable as a 64-bit Long itemReturns an Observable that counts the total number of items emitted by the source Observable and emits this count as a 64-bit Long. |
| public static < the value type emitted T> Observable | Returns: the new Observable instancethe callback to execute for each individual Subscriber that subscribes to the
returned Observable f
Deprecated
1.2.7 - inherently unsafe, use the other create() methods for basic cases or
see
Constructs an Observable in an unsafe manner, that is, unsubscription and backpressure handling
is the responsibility of the OnSubscribe implementation.
unsafeCreate(OnSubscribe) for advanced cases (such as custom operators)
|
| public static < the element type T> Observable | Returns: the new Observable instancethe emitter that is called when a Subscriber subscribes to the returned emitter, Emitter.Observablethe backpressure mode to apply if the downstream Subscriber doesn't request (fast) enough backpressureProvides an API (via a cold Observable) that bridges the reactive world with the callback-style, generally non-backpressured world. |
| public static < the state type S, the type of the items that this Observable emits T> Observable | Returns: an Observable that, when aSubscriber subscribes to it, will execute the specified
functionan implementation of syncOnSubscribe)SyncOnSubscribe. There are many static creation methods
on the class for convenience.Returns an Observable that respects the back-pressure semantics. |
| public static < the state type S, the type of the items that this Observable emits T> Observable | Returns: an Observable that, when aSubscriber subscribes to it, will execute the specified
functionan implementation of asyncOnSubscribe)AsyncOnSubscribe. There are many static creation methods
on the class for convenience.Returns an Observable that respects the back-pressure semantics. |
| public final < the debounce value type (ignored) U> Observable | Returns: an Observable that omits items emitted by the source Observable that are followed by another item within a computed debounce durationfunction to retrieve a sequence that indicates the throttle duration for each item debounceSelector)Returns an Observable that mirrors the source Observable, except that it drops items emitted by the source Observable that are followed by another item within a computed debounce duration. |
| public final Observable | Returns: an Observable that filters out items from the source Observable that are too quickly followed by newer itemsthe time each item has to be "the most recent" of those emitted by the source Observable to
ensure that it's not dropped timeout, TimeUnit the unit)TimeUnit for the timeoutReturns an Observable that mirrors the source Observable, except that it drops items emitted by the source Observable that are followed by newer items before a timeout value expires. |
| public final Observable | Returns: an Observable that filters out items from the source Observable that are too quickly followed by newer itemsthe time each item has to be "the most recent" of those emitted by the source Observable to
ensure that it's not dropped timeout, TimeUnit the unit of time for the specified timeout unit, Scheduler the scheduler)Scheduler to use internally to manage the timers that handle the timeout for each
itemReturns an Observable that mirrors the source Observable, except that it drops items emitted by the source Observable that are followed by newer items before a timeout value expires on a specified Scheduler. |
| public final Observable | Returns: an Observable that emits either the specified default item if the source Observable emits no items, or the items emitted by the source Observablethe item to emit if the source Observable emits no items defaultValue)Returns an Observable that emits the items emitted by the source Observable or a specified default item if the source Observable is empty. |
| public static < the type of the items emitted by the Observable T> Observable | Returns: an Observable whoseObservers' subscriptions trigger an invocation of the given
Observable factory functionthe Observable factory function to invoke for each observableFactory)Observer that subscribes to the
resulting ObservableReturns an Observable that calls an Observable factory to create an Observable for each new Observer that subscribes. |
| public final < the subscription delay value type (ignored) U, the item delay value type (ignored) V> Observable | Returns: an Observable that delays the subscription and emissions of the source Observable via another Observable on a per-item basisa function that returns an Observable that triggers the subscription to the source Observable
once it emits any item subscriptionDelay, Func1<? super T, ? extends Observable<V>> a function that returns an Observable for each item emitted by the source Observable, which is
then used to delay the emission of that item by the resulting Observable until the Observable
returned from itemDelay)itemDelay emits an itemReturns an Observable that delays the subscription to and emissions from the source Observable via another Observable on a per-item basis. |
| public final < the item delay value type (ignored) U> Observable | Returns: an Observable that delays the emissions of the source Observable via another Observable on a per-item basisa function that returns an Observable for each item emitted by the source Observable, which is
then used to delay the emission of that item by the resulting Observable until the Observable
returned from itemDelay)itemDelay emits an itemReturns an Observable that delays the emissions of the source Observable via another Observable on a per-item basis. |
| public final Observable | |
| public final Observable | Returns: the source Observable shifted in time by the specified delaythe delay to shift the source by delay, TimeUnit the time unit of unit, Scheduler delaythe scheduler)Scheduler to use for delayingReturns an Observable that emits the items emitted by the source Observable shifted forward in time by a specified delay. |
| public final Observable | Returns: an Observable that delays the subscription to the source Observable by the given amountthe time to delay the subscription delay, TimeUnit the time unit of unit)delayReturns an Observable that delays the subscription to the source Observable by a given amount of time. |
| public final Observable | Returns: an Observable that delays the subscription to the source Observable by a given amount, waiting and subscribing on the given Schedulerthe time to delay the subscription delay, TimeUnit the time unit of unit, Scheduler delaythe Scheduler on which the waiting and subscription will happen scheduler)Returns an Observable that delays the subscription to the source Observable by a given amount of time, both waiting and subscribing on a given Scheduler. |
| public final < the element type of the delaying Observable U> Observable | Returns: an Observable that delays the subscription to the source Observable until the Observable returned bysubscriptionDelay emits an itema function that returns an Observable that triggers the subscription to the source Observable
once it emits any item subscriptionDelay)Returns an Observable that delays the subscription to the source Observable until a second Observable emits an item. |
| public final < the value type of the other Observable, irrelevant U> Observable | Returns: an Observable that delays the subscription to this Observable until the other Observable emits an element or completes normally.the other Observable that should trigger the subscription
to this Observable. other)Returns an Observable that delays the subscription to this Observable until the other Observable emits an element or completes normally. |
| public final < the output value type T2> Observable | Returns: an Observable that emits the items and notifications embedded in theNotification objects
emitted by the source ObservableReturns an Observable that reverses the effect of |
| public final Observable | Returns: an Observable that emits only those items emitted by the source Observable that are distinct from each otherReturns an Observable that emits all items emitted by the source Observable that are distinct. |
| public final < the key type U> Observable | Returns: an Observable that emits those items emitted by the source Observable that have distinct keysa function that projects an emitted item to a key value that is used to decide whether an item
is distinct from another one or not keySelector)Returns an Observable that emits all items emitted by the source Observable that are distinct according to a key selector function. |
| public final Observable | Returns: an Observable that emits those items from the source Observable that are distinct from their immediate predecessorsReturns an Observable that emits all items emitted by the source Observable that are distinct from their immediate predecessors. |
| public final < the key type U> Observable | Returns: an Observable that emits those items from the source Observable whose keys are distinct from those of their immediate predecessorsa function that projects an emitted item to a key value that is used to decide whether an item
is distinct from another one or not keySelector)Returns an Observable that emits all items emitted by the source Observable that are distinct from their immediate predecessors, according to a key selector function. |
| public final Observable | Returns: an Observable that emits those items from the source Observable that are distinct from their immediate predecessorsthe function that receives the previous item and the current item and is
expected to return true if the two are equal, thus skipping the current value. comparator)Returns an Observable that emits all items emitted by the source Observable that are distinct from their immediate predecessors when compared with each other via the provided comparator function. |
| public final Observable | Returns: an Observable that emits the same items as the source Observable, then invokes theAction0an action)Action0 to be invoked when the source Observable finishesRegisters an |
| public final Observable | Returns: the source Observable with the side-effecting behavior appliedthe action to invoke when the source Observable calls onCompleted)onCompletedModifies the source Observable so that it invokes an action when it calls |
| public final Observable | Returns: the source Observable with the side-effecting behavior appliedthe action to invoke for each item emitted by the source Observable onNotification)Modifies the source Observable so that it invokes an action for each item and terminal event it emits. |
| public final Observable | Returns: the source Observable with the side-effecting behavior appliedthe observer to be notified about onNext, onError and onCompleted events on its
respective methods before the actual downstream Subscriber gets notified. observer)Modifies the source Observable so that it notifies an Observer for each item and terminal event it emits. |
| public final Observable | |
| public final Observable | |
| public final Observable | Returns: the sourceObservable modified so as to call this Action when appropriatethe action that gets called when an observer requests items from this
onRequest)ObservableModifies the source |
| public final Observable | Returns: the sourceObservable modified so as to call this Action when appropriatethe action that gets called when an observer subscribes to the source subscribe)ObservableModifies the source |
| public final Observable | Returns: the source Observable with the side-effecting behavior appliedthe action to invoke when the source Observable calls onTerminate)onCompleted or onErrorModifies the source Observable so that it invokes an action when it calls |
| public final Observable | Returns: the sourceObservable modified so as to call this Action when appropriatethe action that gets called when the source unsubscribe)Observable is unsubscribedCalls the unsubscribe |
| public final Observable | Returns: an Observable that emits a single item: the item at the specified position in the sequence of those emitted by the source Observablethe zero-based index of the item to retrieve index)Returns an Observable that emits the single item at a specified index in a sequence of emissions from a source Observable. |
| public final Observable | Returns: an Observable that emits the item at the specified position in the sequence emitted by the source Observable, or the default item if that index is outside the bounds of the source sequencethe zero-based index of the item to retrieve index, T the default item defaultValue)Returns an Observable that emits the item found at a specified index in a sequence of emissions from a source Observable, or a default item if that index is out of range. |
| public static < the type of the items (ostensibly) emitted by the Observable T> Observable | Returns: an Observable that emits no items to theObserver but immediately invokes the
Observer's onCompleted methodReturns an Observable that emits no items to the |
| public static < the type of the items (ostensibly) emitted by the Observable T> Observable | |
| public final Observable | Returns: an Observable that emits a Boolean that indicates whether any item emitted by the source Observable satisfies thepredicatethe condition to test items emitted by the source Observable predicate)Returns an Observable that emits Note this always emits |
| public final Observable | Returns: an Observable that emits only those items emitted by the source Observable that the filter evaluates astruea function that evaluates each item emitted by the source Observable, returning predicate)true
if it passes the filterFilters items emitted by an Observable by only emitting those that satisfy a specified predicate. |
| public final Observable | Returns: an Observable that emits the same items as the source Observable, then invokes theAction0an action)Action0 to be invoked when the source Observable finishes
Deprecated
use
Registers an doAfterTerminate(Action0) instead.
Action0 to be called when this Observable invokes either
onCompleted or onError.
|
| public final Observable | Returns: an Observable that emits only the very first item emitted by the source Observable, or raises anNoSuchElementException if the source Observable is emptyReturns an Observable that emits only the very first item emitted by the source Observable, or notifies
of an |
| public final Observable | Returns: an Observable that emits only the very first item emitted by the source Observable that satisfies thepredicate, or raises an NoSuchElementException if no such items are emittedthe condition that an item emitted by the source Observable has to satisfy predicate)Returns an Observable that emits only the very first item emitted by the source Observable that satisfies
a specified condition, or notifies of an |
| public final Observable | Returns: an Observable that emits only the very first item from the source, or a default item if the source Observable completes without emitting any itemsthe default item to emit if the source Observable doesn't emit anything defaultValue)Returns an Observable that emits only the very first item emitted by the source Observable, or a default item if the source Observable completes without emitting anything. |
| public final Observable | Returns: an Observable that emits only the very first item emitted by the source Observable that satisfies thepredicate, or a default item if the source Observable emits no such itemsthe default item to emit if the source Observable doesn't emit anything that satisfies the
defaultValue, Func1<? super T, Boolean> predicatethe condition any item emitted by the source Observable has to satisfy predicate)Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition, or a default item if the source Observable emits no such items. |
| public final < the value type of the inner Observables and the output type R> Observable | Returns: an Observable that emits the result of applying the transformation function to each item emitted by the source Observable and merging the results of the Observables obtained from this transformationa function that, when applied to an item emitted by the source Observable, returns an
Observable func)Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then merging those resulting Observables and emitting the results of this merger. |
| public final < the value type of the inner Observables and the output type R> Observable | Returns: an Observable that emits the result of applying the transformation function to each item emitted by the source Observable and merging the results of the Observables obtained from this transformationa function that, when applied to an item emitted by the source Observable, returns an
Observable func, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then merging those resulting Observables and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to these Observables. |
| public final < the result type R> Observable | Returns: an Observable that emits the results of merging the Observables returned from applying the specified functions to the emissions and notifications of the source Observablea function that returns an Observable to merge for each item emitted by the source Observable onNext, Func1<? super Throwable, ? extends Observable<? extends R>> a function that returns an Observable to merge for an onError notification from the source
Observable onError, Func0<? extends Observable<? extends R>> a function that returns an Observable to merge for an onCompleted notification from the source
Observable onCompleted)Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items. |
| public final < the result type R> Observable | Returns: an Observable that emits the results of merging the Observables returned from applying the specified functions to the emissions and notifications of the source Observablea function that returns an Observable to merge for each item emitted by the source Observable onNext, Func1<? super Throwable, ? extends Observable<? extends R>> a function that returns an Observable to merge for an onError notification from the source
Observable onError, Func0<? extends Observable<? extends R>> a function that returns an Observable to merge for an onCompleted notification from the source
Observable onCompleted, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to these Observables. |
| public final < the type of items emitted by the collection Observable U, the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits the results of applying a function to a pair of values emitted by the source Observable and the collection Observablea function that returns an Observable for each item emitted by the source Observable collectionSelector, final Func2<? super T, ? super U, ? extends R> a function that combines one item emitted by each of the source and collection Observables and
returns an item to be emitted by the resulting Observable resultSelector)Returns an Observable that emits the results of a specified function to the pair of values emitted by the source Observable and a specified collection Observable. |
| public final < the type of items emitted by the collection Observable U, the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits the results of applying a function to a pair of values emitted by the source Observable and the collection Observablea function that returns an Observable for each item emitted by the source Observable collectionSelector, final Func2<? super T, ? super U, ? extends R> a function that combines one item emitted by each of the source and collection Observables and
returns an item to be emitted by the resulting Observable resultSelector, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Returns an Observable that emits the results of a specified function to the pair of values emitted by the source Observable and a specified collection Observable, while limiting the maximum number of concurrent subscriptions to these Observables. |
| public final Observable | Returns: the new Observable instancethe function that receives an upstream value and turns it into a Completable
to be merged. mapper)Maps all upstream values to Completables and runs them together until the upstream and all inner Completables complete normally. |
| public final Observable | Returns: the new Observable instancethe function that receives an upstream value and turns it into a Completable
to be merged. mapper, boolean if true, errors from the upstream and from the inner Completables get delayed till
the all of them terminate. delayErrors)Maps all upstream values to Completables and runs them together, optionally delaying any errors, until the upstream and all inner Completables terminate. |
| public final Observable | Returns: the new Observable instancethe function that receives an upstream value and turns it into a Completable
to be merged. mapper, boolean if true, errors from the upstream and from the inner Completables get delayed till
the all of them terminate. delayErrors, int the maximum number of inner Completables to run at a time maxConcurrency)Maps upstream values to Completables and runs up to the given number of them together at a time, optionally delaying any errors, until the upstream and all inner Completables terminate. |
| public final < the type of item emitted by the resulting Observable R> Observable | Returns: an Observable that emits the results of merging the items emitted by the source Observable with the values in the Iterables corresponding to those items, as generated bycollectionSelectora function that returns an Iterable sequence of values for when given an item emitted by the
source Observable collectionSelector)Returns an Observable that merges each item emitted by the source Observable with the values in an Iterable corresponding to that item that is generated by a selector. |
| public final < the type of item emitted by the resulting Observable R> Observable | Returns: an Observable that emits the results of merging the items emitted by the source Observable with the values in the Iterables corresponding to those items, as generated bycollectionSelectora function that returns an Iterable sequence of values for when given an item emitted by the
source Observable collectionSelector, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Returns an Observable that merges each item emitted by the source Observable with the values in an Iterable corresponding to that item that is generated by a selector, while limiting the number of concurrent subscriptions to these Observables. |
| public final < the collection element type U, the type of item emitted by the resulting Observable R> Observable | Returns: an Observable that emits the items returned byresultSelector for each item in the source
Observablea function that returns an Iterable sequence of values for each item emitted by the source
Observable collectionSelector, Func2<? super T, ? super U, ? extends R> a function that returns an item based on the item emitted by the source Observable and the
Iterable returned for that item by the resultSelector)collectionSelectorReturns an Observable that emits the results of applying a function to the pair of values from the source Observable and an Iterable corresponding to that item that is generated by a selector. |
| public final < the collection element type U, the type of item emitted by the resulting Observable R> Observable | Returns: an Observable that emits the items returned byresultSelector for each item in the source
Observablea function that returns an Iterable sequence of values for each item emitted by the source
Observable collectionSelector, Func2<? super T, ? super U, ? extends R> a function that returns an item based on the item emitted by the source Observable and the
Iterable returned for that item by the resultSelector, int collectionSelectorthe maximum number of Observables that may be subscribed to concurrently maxConcurrent)Returns an Observable that emits the results of applying a function to the pair of values from the source Observable and an Iterable corresponding to that item that is generated by a selector, while limiting the number of concurrent subscriptions to these Observables. |
| public final < the value type of the inner Singles and the resulting Observable R> Observable | Returns: the new Observable instancethe function that receives an upstream value and turns it into a Single
to be merged. mapper)Maps all upstream values to Singles and runs them together until the upstream and all inner Singles complete normally. |
| public final < the value type of the inner Singles and the resulting Observable R> Observable | Returns: the new Observable instancethe function that receives an upstream value and turns it into a Single
to be merged. mapper, boolean if true, errors from the upstream and from the inner Singles get delayed till
the all of them terminate. delayErrors)Maps all upstream values to Singles and runs them together, optionally delaying any errors, until the upstream and all inner Singles terminate. |
| public final < the value type of the inner Singles and the resulting Observable R> Observable | Returns: the new Observable instancethe function that receives an upstream value and turns it into a Single
to be merged. mapper, boolean if true, errors from the upstream and from the inner Singles get delayed till
the all of them terminate. delayErrors, int the maximum number of inner Singles to run at a time maxConcurrency)Maps upstream values to Singles and runs up to the given number of them together at a time, optionally delaying any errors, until the upstream and all inner Singles terminate. |
| public final void | forEach(final Action1<? super T>
Action1 to execute for each item.Subscribes to the |
| public final void | |
| public final void | forEach(final Action1<? super T>
Action1 to execute for each item.Action1 to execute when an error is emitted.Action0 to execute when completion is signalled.Subscribes to the |
| public static < the type of object that the T> ObservableFuture returns, and also the type of item to be emitted by
the resulting Observable | |
| public static < the type of object that the T> ObservableFuture returns, and also the type of item to be emitted by
the resulting Observable | |
| public static < the type of object that the T> ObservableFuture returns, and also the type of item to be emitted by
the resulting Observable | Returns: an Observable that emits the item from the sourceFuturethe source future, Scheduler Futurethe scheduler)Scheduler to wait for the Future on. Use a Scheduler such as
Schedulers#io() that can block and wait on the FutureConverts a |
| public static < the type of items in the T> ObservableIterable sequence and the type of items to be emitted by the
resulting Observable | |
| public static < the type of items in the Array and the type of items to be emitted by the resulting Observable T> Observable | Returns: an Observable that emits each item in the source Arraythe source Array array)Converts an Array into an Observable that emits the items in the Array. |
| public static < the type of the item emitted by the Observable T> Observable | Returns: an Observable whoseObservers' subscriptions trigger an invocation of the given functiona function, the execution of which should be deferred; func)fromCallable will invoke this
function only when an observer subscribes to the Observable that fromCallable returnsReturns an Observable that, when an observer subscribes to it, invokes a function you specify and then emits the value returned from that function. |
| public final < the key type K, the element type R> Observable | Returns: anObservable that emits GroupedObservables, each of which corresponds to a
unique key value and each of which emits those items from the source Observable that share that
key valuea function that extracts the key for each item keySelector, final Func1<? super T, ? extends R> a function that extracts the return element for each item elementSelector)Groups the items emitted by an |
| public final < the key type K, the element type R> Observable | Returns: anObservable that emits GroupedObservables, each of which corresponds to a
unique key value and each of which emits those items from the source Observable that share that
key valuea function that extracts the key for each item keySelector, final Func1<? super T, ? extends R> a function that extracts the return element for each item elementSelector, final Func1<Action1<K>, Map<K, Object>> a function that given an eviction action returns a evictingMapFactory)Map instance that will be used to assign
items to the appropriate GroupedObservables. The Map instance must be thread-safe
and any eviction must trigger a call to the supplied action (synchronously or asynchronously).
This can be used to limit the size of the map by evicting keys by maximum size or access time for
instance. Here's an example using Guava's CacheBuilder from v19.0:
Deprecated
since 1.3.7, use
Groups the items emitted by an groupBy(Func1, Func1, int, boolean, Func1)
instead which uses much less memory.
Observable according to a specified criterion, and emits these
grouped items as GroupedObservables.
|
| public final < the key type K, the element type R> Observable | Returns: anObservable that emits GroupedObservables, each of which corresponds to a
unique key value and each of which emits those items from the source Observable that share that
key valuea function that extracts the key for each item keySelector, final Func1<? super T, ? extends R> a function that extracts the return element for each item elementSelector, int the size of the buffer ( bufferSize, boolean RxRingBuffer. may be suitable).if and only if false then onError emissions can shortcut onNext emissions (emissions may be buffered) delayError, final Func1<Action1<Object>, Map<K, Object>> a function that given an eviction action returns a evictingMapFactory)Map instance that will be used to assign
items to the appropriate GroupedObservables. The Map instance must be thread-safe
and any eviction must trigger a call to the supplied action (synchronously or asynchronously).
This can be used to limit the size of the map by evicting entries by map maximum size or access time for
instance. Here's an example using Guava's CacheBuilder from v24.0:
Groups the items emitted by an |
| public final < the key type K> Observable | Returns: anObservable that emits GroupedObservables, each of which corresponds to a
unique key value and each of which emits those items from the source Observable that share that
key valuea function that extracts the key for each item keySelector)Groups the items emitted by an |
| public final < the value type of the right Observable source T2, the element type of the left duration Observables D1, the element type of the right duration Observables D2, the result type R> Observable | Returns: an Observable that emits items based on combining those items emitted by the source Observables whose durations overlapthe other Observable to correlate items from the source Observable with right, Func1<? super T, ? extends Observable<D1>> a function that returns an Observable whose emissions indicate the duration of the values of
the source Observable leftDuration, Func1<? super T2, ? extends Observable<D2>> a function that returns an Observable whose emissions indicate the duration of the values of
the rightDuration, Func2<? super T, ? super Observable<T2>, ? extends R> right Observablea function that takes an item emitted by each Observable and returns the value to be emitted
by the resulting Observable resultSelector)Returns an Observable that correlates two Observables when they overlap in time and groups the results. |
| public final Observable | Returns: an empty Observable that only callsonCompleted or onError, based on which one is
called by the source ObservableIgnores all items emitted by the source Observable and only calls |
| public static Observable | |
| public static Observable | Returns: an Observable that emits a sequential number each time intervalinterval size in time units (see below) interval, TimeUnit time units to use for the interval size unit, Scheduler the Scheduler to use for scheduling the items scheduler)Returns an Observable that emits a sequential number every specified interval of time, on a specified Scheduler. |
| public static Observable | Returns: an Observable that emits a 0L after theinitialDelay and ever increasing numbers after
each period of time thereafterthe initial delay time to wait before emitting the first value of 0L initialDelay, long the period of time between emissions of the subsequent numbers period, TimeUnit the time unit for both unit)initialDelay and periodReturns an Observable that emits a |
| public static Observable | Returns: an Observable that emits a 0L after theinitialDelay and ever increasing numbers after
each period of time thereafter, while running on the given Schedulerthe initial delay time to wait before emitting the first value of 0L initialDelay, long the period of time between emissions of the subsequent numbers period, TimeUnit the time unit for both unit, Scheduler initialDelay and periodthe Scheduler on which the waiting happens and items are emitted scheduler)Returns an Observable that emits a |
| public final Observable | Returns: an Observable that emits a BooleanReturns an Observable that emits |
| public final < the value type of the right Observable source TRight, the element type of the left duration Observables TLeftDuration, the element type of the right duration Observables TRightDuration, the result type R> Observable | Returns: an Observable that emits items correlating to items emitted by the source Observables that have overlapping durationsthe second Observable to join items from right, Func1<T, Observable<TLeftDuration>> a function to select a duration for each item emitted by the source Observable, used to
determine overlap leftDurationSelector, Func1<TRight, Observable<TRightDuration>> a function to select a duration for each item emitted by the rightDurationSelector, Func2<T, TRight, R> right Observable, used to
determine overlapa function that computes an item to be emitted by the resulting Observable for any two
overlapping items emitted by the two Observables resultSelector)Correlates the items emitted by two Observables based on overlapping durations. |
| public static < the type of that item T> Observable | Returns: an Observable that emitsvalue as a single item and then completesthe item to emit value)Returns an Observable that emits a single item and then completes. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2)Converts two items into an Observable that emits those items. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2, T third item t3)Converts three items into an Observable that emits those items. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2, T third item t3, T fourth item t4)Converts four items into an Observable that emits those items. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2, T third item t3, T fourth item t4, T fifth item t5)Converts five items into an Observable that emits those items. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2, T third item t3, T fourth item t4, T fifth item t5, T sixth item t6)Converts six items into an Observable that emits those items. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2, T third item t3, T fourth item t4, T fifth item t5, T sixth item t6, T seventh item t7)Converts seven items into an Observable that emits those items. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2, T third item t3, T fourth item t4, T fifth item t5, T sixth item t6, T seventh item t7, T eighth item t8)Converts eight items into an Observable that emits those items. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2, T third item t3, T fourth item t4, T fifth item t5, T sixth item t6, T seventh item t7, T eighth item t8, T ninth item t9)Converts nine items into an Observable that emits those items. |
| public static < the type of these items T> Observable | Returns: an Observable that emits each itemfirst item t1, T second item t2, T third item t3, T fourth item t4, T fifth item t5, T sixth item t6, T seventh item t7, T eighth item t8, T ninth item t9, T tenth item t10)Converts ten items into an Observable that emits those items. |
| public final Observable | Returns: an Observable that emits the last item from the source Observable or notifies observers of an errorReturns an Observable that emits the last item emitted by the source Observable or notifies observers of
a |
| public final Observable | Returns: an Observable that emits only the last item satisfying the given condition from the source, or anNoSuchElementException if no such items are emittedthe condition any source emitted item has to satisfy predicate)Returns an Observable that emits only the last item emitted by the source Observable that satisfies a
given condition, or notifies of a |
| public final Observable | Returns: an Observable that emits only the last item emitted by the source Observable, or a default item if the source Observable is emptythe default item to emit if the source Observable is empty defaultValue)Returns an Observable that emits only the last item emitted by the source Observable, or a default item if the source Observable completes without emitting any items. |
| public final Observable | Returns: an Observable that emits only the last item emitted by the source Observable that satisfies the given condition, or a default item if no such item is emitted by the source Observablethe default item to emit if the source Observable doesn't emit anything that satisfies the
specified defaultValue, Func1<? super T, Boolean> predicatethe condition any item emitted by the source Observable has to satisfy predicate)Returns an Observable that emits only the last item emitted by the source Observable that satisfies a specified condition, or a default item if no such item is emitted by the source Observable. |
| public final < the output value type R> Observable | Returns: an Observable that is the result of applying the lifted Operator to the source Observablethe Operator that implements the Observable-operating function to be applied to the source
Observable operatorThis method requires advanced knowledge about building operators; please consider other standard composition methods first; Lifts a function to the current Observable and returns a new Observable that when subscribed to will pass the values of the current Observable through the Operator function. |
| public final Observable | Returns: an Observable that emits only the firstcount items emitted by the source Observable, or
all of the items from the source Observable if that Observable emits fewer than count itemsthe maximum number of items to emit count)Returns an Observable that emits only the first |
| public final < the output type R> Observable | Returns: an Observable that emits the items from the source Observable, transformed by the specified functiona function to apply to each item emitted by the Observable func)Returns an Observable that applies a specified function to each item emitted by the source Observable and emits the results of these function applications. |
| private <R> Observable | mapNotification(Func1<? super T, ? extends R> onNext, Func1<? super Throwable, ? extends R> onError, Func0<? extends R> onCompleted)
|
| public final Observable | Returns: an Observable that emits items that are the result of materializing the items and notifications of the source ObservableReturns an Observable that represents all of the emissions and notifications from the source
Observable into emissions marked with their original types within |
| public static < the common element base type T> Observable | Returns: an Observable that emits items that are the result of flattening the items emitted by the Observables in the Iterablethe Iterable of Observables sequences)Flattens an Iterable of Observables into one Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items that are the result of flattening the items emitted by the Observables in the Iterablethe Iterable of Observables sequences, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Flattens an Iterable of Observables into one Observable, without any transformation, while limiting the number of concurrent subscriptions to these Observables. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items that are the result of flattening the Observables emitted by thesource Observablean Observable that emits Observables source)Flattens an Observable that emits Observables into a single Observable that emits the items emitted by those Observables, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items that are the result of flattening the Observables emitted by thesource Observablean Observable that emits Observables source, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Flattens an Observable that emits Observables into a single Observable that emits the items emitted by those Observables, without any transformation, while limiting the maximum number of concurrent subscriptions to these Observables. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2)Flattens two Observables into a single Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3)Flattens three Observables into a single Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4)Flattens four Observables into a single Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5)Flattens five Observables into a single Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5, Observable<? extends T> an Observable to be merged t6)Flattens six Observables into a single Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5, Observable<? extends T> an Observable to be merged t6, Observable<? extends T> an Observable to be merged t7)Flattens seven Observables into a single Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5, Observable<? extends T> an Observable to be merged t6, Observable<? extends T> an Observable to be merged t7, Observable<? extends T> an Observable to be merged t8)Flattens eight Observables into a single Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5, Observable<? extends T> an Observable to be merged t6, Observable<? extends T> an Observable to be merged t7, Observable<? extends T> an Observable to be merged t8, Observable<? extends T> an Observable to be merged t9)Flattens nine Observables into a single Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the Observables in the Arraythe Array of Observables sequences)Flattens an Array of Observables into one Observable, without any transformation. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the Observables in the Arraythe Array of Observables sequences, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Flattens an Array of Observables into one Observable, without any transformation, while limiting the number of concurrent subscriptions to these Observables. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the Observables emitted by thesource Observablean Observable that emits Observables source)Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items emitted by the Observables emitted by thesource Observablean Observable that emits Observables source, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to these Observables. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items that are the result of flattening the items emitted by the Observables in the Iterablethe Iterable of Observables sequences)Flattens an Iterable of Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from each of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits items that are the result of flattening the items emitted by the Observables in the Iterablethe Iterable of Observables sequences, int the maximum number of Observables that may be subscribed to concurrently maxConcurrent)Flattens an Iterable of Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from each of the source Observables without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to these Observables. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items that are emitted by the two source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2)Flattens two Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from each of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items that are emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3)Flattens three Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items that are emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4)Flattens four Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items that are emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5)Flattens five Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items that are emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5, Observable<? extends T> an Observable to be merged t6)Flattens six Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items that are emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5, Observable<? extends T> an Observable to be merged t6, Observable<? extends T> an Observable to be merged t7)Flattens seven Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items that are emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5, Observable<? extends T> an Observable to be merged t6, Observable<? extends T> an Observable to be merged t7, Observable<? extends T> an Observable to be merged t8)Flattens eight Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them. |
| public static < the common element base type T> Observable | Returns: an Observable that emits all of the items that are emitted by the source Observablesan Observable to be merged t1, Observable<? extends T> an Observable to be merged t2, Observable<? extends T> an Observable to be merged t3, Observable<? extends T> an Observable to be merged t4, Observable<? extends T> an Observable to be merged t5, Observable<? extends T> an Observable to be merged t6, Observable<? extends T> an Observable to be merged t7, Observable<? extends T> an Observable to be merged t8, Observable<? extends T> an Observable to be merged t9)Flattens nine Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them. |
| public final Observable | Returns: an Observable that emits all of the items emitted by the source Observablesan Observable to be merged t1)Flattens this and another Observable into a single Observable, without any transformation. |
| public final Observable | Returns: an Observable that emits a single item: the source ObservableConverts the source |
| public static < the type of items (not) emitted by the Observable T> Observable | |
| public final Observable | observeOn(Scheduler scheduler)
Modifies an Observable to perform its emissions and notifications on a specified |
| public final Observable | |
| public final Observable | observeOn(Scheduler scheduler, boolean
indicates if the onError notification may not cut ahead of onNext notification on the other side of the
scheduling boundary. If true a sequence ending in onError will be replayed in the same order as was received
from upstream delayError)Modifies an Observable to perform its emissions and notifications on a specified |
| public final Observable | observeOn(Scheduler scheduler, boolean
indicates if the onError notification may not cut ahead of onNext notification on the other side of the
scheduling boundary. If true a sequence ending in onError will be replayed in the same order as was received
from upstream delayError, int the size of the buffer. bufferSize)Modifies an Observable to perform its emissions and notifications on a specified |
| public final < the output type R> Observable | |
| public final Observable | Returns: the source Observable modified to buffer items to the extent system resources allowInstructs an Observable that is emitting items faster than its observer can consume them to buffer these items indefinitely until they can be emitted. |
| public final Observable | Returns: the sourceObservable modified to buffer items up to the given capacity.number of slots available in the buffer. capacity)Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to a given amount of items until they can be emitted. |
| public final Observable | Returns: the sourceObservable modified to buffer items up to the given capacitynumber of slots available in the buffer. capacity, Action0 action to execute if an item needs to be buffered, but there are no available slots. Null is allowed. onOverflow)Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to a given amount of items until they can be emitted. |
| public final Observable | Returns: the sourceObservable modified to buffer items up to the given capacitynumber of slots available in the buffer. capacity, Action0 action to execute if an item needs to be buffered, but there are no available slots. Null is allowed. onOverflow, BackpressureOverflow.how should the overflowStrategyObservable react to buffer overflows. Null is not allowed.Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to a given amount of items until they can be emitted. |
| public final Observable | Returns: the source Observable modified to droponNext notifications on overflowthe action to invoke for each item dropped. onDrop action should be fast and should never block. onDrop)Instructs an Observable that is emitting items faster than its observer can consume them to discard, rather than emit, those items that its observer is not prepared to observe. |
| public final Observable | Returns: the source Observable modified to droponNext notifications on overflowInstructs an Observable that is emitting items faster than its observer can consume them to discard, rather than emit, those items that its observer is not prepared to observe. |
| public final Observable | Returns: the source Observable modified so that it emits the most recently-received item upon requestInstructs an Observable that is emitting items faster than its observer can consume them to hold onto the latest value and emit that on request. |
| public final Observable | Returns: the original Observable, with appropriately modified behaviora function that returns an Observable that will take over if the source Observable encounters
an error resumeFunction)Instructs an Observable to pass control to another Observable rather than invoking
|
| public final Observable | Returns: the original Observable, with appropriately modified behaviora function that returns an Observable that will take over if the source Observable encounters
an error resumeSequence)Instructs an Observable to pass control to another Observable rather than invoking
|
| public final Observable | Returns: the original Observable with appropriately modified behaviora function that returns an item that the new Observable will emit if the source Observable
encounters an error resumeFunction)Instructs an Observable to emit an item (returned by a specified function) rather than invoking
|
| public final Observable | Returns: the original Observable, with appropriately modified behaviora function that returns an Observable that will take over if the source Observable encounters
an exception resumeSequence)Instructs an Observable to pass control to another Observable rather than invoking
|
| public final Observable | Returns: an Observable which out references to the upstream producer and downstream Subscriber if the sequence is terminated or downstream unsubscribesNulls out references to the upstream producer and downstream Subscriber if the sequence is terminated or downstream unsubscribes. |
| public final ConnectableObservable | Returns: aConnectableObservable that upon connection causes the source Observable to emit items
to its ObserversReturns a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits the results of invoking the selector on the items emitted by aConnectableObservable that shares a single subscription to the underlying sequencea function that can use the multicasted source sequence as many times as needed, without
causing multiple subscriptions to the source sequence. Subscribers to the given source will
receive all notifications of the source from the time of the subscription forward. selector)Returns an Observable that emits the results of invoking a specified selector on items emitted by a
|
| public static Observable | Returns: an Observable that emits a range of sequential Integersthe value of the first Integer in the sequence start, int the number of sequential Integers to generate count)Returns an Observable that emits a sequence of Integers within a specified range. |
| public static Observable | Returns: an Observable that emits a range of sequential Integersthe value of the first Integer in the sequence start, int the number of sequential Integers to generate count, Scheduler the Scheduler to run the generator loop on scheduler)Returns an Observable that emits a sequence of Integers within a specified range, on a specified Scheduler. |
| public final Observable | Returns: the Observable that rebatches request amounts from downstreamthe initial request amount, further request will happen after 75% of this value n)Requests |
| public final Observable | Returns: an Observable that emits a single item that is the result of accumulating the items emitted by the source Observablean accumulator function to be invoked on each item emitted by the source Observable, whose
result will be used in the next accumulator call accumulator)Returns an Observable that applies a specified accumulator function to the first item emitted by a source Observable, then feeds the result of that function along with the second item emitted by the source Observable into the same function, and so on until all items have been emitted by the source Observable, and emits the final result from the final call to your function as its sole item. |
| public final < the accumulator and output value type R> Observable | Returns: an Observable that emits a single item that is the result of accumulating the output from the items emitted by the source Observablethe initial (seed) accumulator value initialValue, Func2<R, ? super T, R> an accumulator function to be invoked on each item emitted by the source Observable, the
result of which will be used in the next accumulator call accumulator)Returns an Observable that applies a specified accumulator function to the first item emitted by a source Observable and a specified seed value, then feeds the result of that function along with the second item emitted by an Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the final result from the final call to your function as its sole item. |
| public final Observable | Returns: an Observable that emits the items emitted by the source Observable repeatedly and in sequenceReturns an Observable that repeats the sequence of items emitted by the source Observable indefinitely. |
| public final Observable | |
| public final Observable | Returns: an Observable that repeats the sequence of items emitted by the source Observable at mostcount timesthe number of times the source Observable items are repeated, a count of 0 will yield an empty
sequence count)Returns an Observable that repeats the sequence of items emitted by the source Observable at most
|
| public final Observable | Returns: an Observable that repeats the sequence of items emitted by the source Observable at mostcount times on a particular Schedulerthe number of times the source Observable items are repeated, a count of 0 will yield an empty
sequence count, Scheduler the scheduler)Scheduler to emit the items onReturns an Observable that repeats the sequence of items emitted by the source Observable at most
|
| public final Observable | Returns: the source Observable modified with repeat logicreceives an Observable of notifications with which a user can complete or error, aborting the repeat. notificationHandler, Scheduler the scheduler)Scheduler to emit the items onReturns an Observable that emits the same values as the source Observable with the exception of an
|
| public final Observable | Returns: the source Observable modified with repeat logicreceives an Observable of notifications with which a user can complete or error, aborting the repeat. notificationHandler)Returns an Observable that emits the same values as the source Observable with the exception of an
|
| public final ConnectableObservable | Returns: aConnectableObservable that upon connection causes the source Observable to emit its
items to its ObserversReturns a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits items that are the results of invoking the selector on aConnectableObservable that shares a single subscription to the source Observablethe selector function, which can use the multicasted sequence as many times as needed, without
causing multiple subscriptions to the Observable selector)Returns an Observable that emits items that are the results of invoking a specified selector on the items
emitted by a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits items that are the results of invoking the selector on items emitted by aConnectableObservable that shares a single subscription to the source Observable
replaying no more than bufferSize itemsthe selector function, which can use the multicasted sequence as many times as needed, without
causing multiple subscriptions to the Observable selector, final int the buffer size that limits the number of items the connectable observable can replay bufferSize)Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits items that are the results of invoking the selector on items emitted by aConnectableObservable that shares a single subscription to the source Observable, and
replays no more than bufferSize items that were emitted within the window defined by
timea selector function, which can use the multicasted sequence as many times as needed, without
causing multiple subscriptions to the Observable selector, int the buffer size that limits the number of items the connectable observable can replay bufferSize, long the duration of the window in which the replayed items must have been emitted time, TimeUnit the time unit of unit)timeReturns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits items that are the results of invoking the selector on items emitted by aConnectableObservable that shares a single subscription to the source Observable, and
replays no more than bufferSize items that were emitted within the window defined by
timea selector function, which can use the multicasted sequence as many times as needed, without
causing multiple subscriptions to the Observable selector, final int the buffer size that limits the number of items the connectable observable can replay bufferSize, final long the duration of the window in which the replayed items must have been emitted time, final TimeUnit the time unit of unit, final Scheduler timethe Scheduler that is the time source for the window scheduler)Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits items that are the results of invoking the selector on items emitted by aConnectableObservable that shares a single subscription to the source Observable,
replaying no more than bufferSize notificationsa selector function, which can use the multicasted sequence as many times as needed, without
causing multiple subscriptions to the Observable selector, final int the buffer size that limits the number of items the connectable observable can replay bufferSize, final Scheduler the Scheduler on which the replay is observed scheduler)Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits items that are the results of invoking the selector on items emitted by aConnectableObservable that shares a single subscription to the source Observable,
replaying all items that were emitted within the window defined by timea selector function, which can use the multicasted sequence as many times as needed, without
causing multiple subscriptions to the Observable selector, long the duration of the window in which the replayed items must have been emitted time, TimeUnit the time unit of unit)timeReturns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits items that are the results of invoking the selector on items emitted by aConnectableObservable that shares a single subscription to the source Observable,
replaying all items that were emitted within the window defined by timea selector function, which can use the multicasted sequence as many times as needed, without
causing multiple subscriptions to the Observable selector, final long the duration of the window in which the replayed items must have been emitted time, final TimeUnit the time unit of unit, final Scheduler timethe scheduler that is the time source for the window scheduler)Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a |
| public final < the type of items emitted by the resulting Observable R> Observable | Returns: an Observable that emits items that are the results of invoking the selector on items emitted by aConnectableObservable that shares a single subscription to the source Observable,
replaying all itemsa selector function, which can use the multicasted sequence as many times as needed, without
causing multiple subscriptions to the Observable selector, final Scheduler the Scheduler where the replay is observed scheduler)Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a |
| public final ConnectableObservable | Returns: aConnectableObservable that shares a single subscription to the source Observable and
replays at most bufferSize items emitted by that Observablethe buffer size that limits the number of items that can be replayed bufferSize)Returns a |
| public final ConnectableObservable | Returns: aConnectableObservable that shares a single subscription to the source Observable and
replays at most bufferSize items that were emitted during the window defined by
timethe buffer size that limits the number of items that can be replayed bufferSize, long the duration of the window in which the replayed items must have been emitted time, TimeUnit the time unit of unit)timeReturns a |
| public final ConnectableObservable | Returns: aConnectableObservable that shares a single subscription to the source Observable and
replays at most bufferSize items that were emitted during the window defined by
timethe buffer size that limits the number of items that can be replayed bufferSize, final long the duration of the window in which the replayed items must have been emitted time, final TimeUnit the time unit of unit, final Scheduler timethe scheduler that is used as a time source for the window scheduler)Returns a |
| public final ConnectableObservable | Returns: aConnectableObservable that shares a single subscription to the source Observable and
replays at most bufferSize items that were emitted by the Observablethe buffer size that limits the number of items that can be replayed bufferSize, final Scheduler the scheduler on which the Observers will observe the emitted items scheduler)Returns a |
| public final ConnectableObservable | Returns: aConnectableObservable that shares a single subscription to the source Observable and
replays the items that were emitted during the window defined by timethe duration of the window in which the replayed items must have been emitted time, TimeUnit the time unit of unit)timeReturns a |
| public final ConnectableObservable | Returns: aConnectableObservable that shares a single subscription to the source Observable and
replays the items that were emitted during the window defined by timethe duration of the window in which the replayed items must have been emitted time, final TimeUnit the time unit of unit, final Scheduler timethe Scheduler that is the time source for the window scheduler)Returns a |
| public final ConnectableObservable | Returns: aConnectableObservable that shares a single subscription to the source Observable that
will replay all of its items and notifications to any future Observer on the given
Schedulerthe Scheduler on which the Observers will observe the emitted items scheduler)Returns a |
| public final Observable | Returns: the source Observable modified with retry logicReturns an Observable that mirrors the source Observable, resubscribing to it if it calls |
| public final Observable | Returns: the source Observable modified with retry logicnumber of retry attempts before failing count)Returns an Observable that mirrors the source Observable, resubscribing to it if it calls |
| public final Observable | Returns: the source Observable modified with retry logicthe predicate that determines if a resubscription may happen in case of a specific exception
and retry count predicate)Returns an Observable that mirrors the source Observable, resubscribing to it if it calls |
| public final Observable | Returns: the source Observable modified with retry logicreceives an Observable of notifications with which a user can complete or error, aborting the
retry notificationHandler)Returns an Observable that emits the same values as the source observable with the exception of an
|
| public final Observable | Returns: the source Observable modified with retry logicreceives an Observable of notifications with which a user can complete or error, aborting the
retry notificationHandler, Scheduler the scheduler)Scheduler on which to subscribe to the source ObservableReturns an Observable that emits the same values as the source observable with the exception of an
|
| public final Observable | Returns: an Observable that emits the results of sampling the items emitted by the source Observable at the specified time intervalthe sampling rate period, TimeUnit the unit)TimeUnit in which period is definedReturns an Observable that emits the most recently emitted item (if any) emitted by the source Observable within periodic time intervals. |
| public final Observable | Returns: an Observable that emits the results of sampling the items emitted by the source Observable at the specified time intervalthe sampling rate period, TimeUnit the unit, Scheduler TimeUnit in which period is definedthe scheduler)Scheduler to use when samplingReturns an Observable that emits the most recently emitted item (if any) emitted by the source Observable within periodic time intervals, where the intervals are defined on a particular Scheduler. |
| public final < the element type of the sampler Observable U> Observable | Returns: an Observable that emits the results of sampling the items emitted by this Observable whenever thesampler Observable emits an item or completesthe Observable to use for sampling the source Observable sampler)Returns an Observable that, when the specified |
| public final Observable | Returns: an Observable that emits the results of each call to the accumulator functionReturns an Observable that applies a specified accumulator function to the first item emitted by a source Observable, then feeds the result of that function along with the second item emitted by the source Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the result of each of these iterations. |
| public final < the initial, accumulator and result type R> Observable | Returns: an Observable that emitsinitialValue followed by the results of each call to the
accumulator functionthe initial (seed) accumulator item initialValue, Func2<R, ? super T, R> accumulator)Returns an Observable that applies a specified accumulator function to the first item emitted by a source Observable and a seed value, then feeds the result of that function along with the second item emitted by the source Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the result of each of these iterations. |
| public static < the type of items emitted by each Observable T> Observable | Returns: an Observable that emits a Boolean value that indicates whether the two sequences are the samethe first Observable to compare first, Observable<? extends T> the second Observable to compare second)Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the same by comparing the items emitted by each Observable pairwise. |
| public static < the type of items emitted by each Observable T> Observable | Returns: an Observable that emits a Boolean value that indicates whether the two Observable two sequences are the same according to the specified functionthe first Observable to compare first, Observable<? extends T> the second Observable to compare second, Func2<? super T, ? super T, Boolean> a function used to compare items emitted by each Observable equality)Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the same by comparing the items emitted by each Observable pairwise based on the results of a specified equality function. |
| public final Observable | Returns: anObservable that is guaranteed to be well-behaved and to make only serialized calls to
its observersForces an Observable's emissions and notifications to be serialized and for it to obey the Observable contract in other ways. |
| public final Observable | Returns: anObservable that upon connection causes the source Observable to emit items
to its ObserversReturns a new |
| public final Observable | Returns: an Observable that emits the single item emitted by the source ObservableReturns an Observable that emits the single item emitted by the source Observable, if that Observable emits only a single item. |
| public final Observable | Returns: an Observable that emits the single item emitted by the source Observable that matches the predicatea predicate function to evaluate items emitted by the source Observable predicate)Returns an Observable that emits the single item emitted by the source Observable that matches a specified predicate, if that Observable emits one such item. |
| public final Observable | Returns: an Observable that emits the single item emitted by the source Observable, or a default item if the source Observable is emptya default value to emit if the source Observable emits no item defaultValue)Returns an Observable that emits the single item emitted by the source Observable, if that Observable emits only a single item, or a default item if the source Observable emits no items. |
| public final Observable | Returns: an Observable that emits the single item emitted by the source Observable that matches the predicate, or the default item if no emitted item matches the predicatea default item to emit if the source Observable emits no matching items defaultValue, Func1<? super T, Boolean> a predicate function to evaluate items emitted by the source Observable predicate)Returns an Observable that emits the single item emitted by the source Observable that matches a predicate, if that Observable emits only one such item, or a default item if the source Observable emits no such items. |
| public final Observable | Returns: an Observable that is identical to the source Observable except that it does not emit the firstcount items that the source Observable emitsthe number of items to skip count)Returns an Observable that skips the first |
| public final Observable | Returns: an Observable that skips values emitted by the source Observable before the time window defined bytime elapses and the emits the remainderthe length of the time window to skip time, TimeUnit the time unit of unit)timeReturns an Observable that skips values emitted by the source Observable before a specified time window elapses. |
| public final Observable | Returns: an Observable that skips values emitted by the source Observable before the time window defined bytime and scheduler elapses, and then emits the remainderthe length of the time window to skip time, TimeUnit the time unit of unit, Scheduler timethe scheduler)Scheduler on which the timed wait happensReturns an Observable that skips values emitted by the source Observable before a specified time window
on a specified |
| public final Observable | Returns: an Observable that emits the items emitted by the source Observable except for the dropped ones at the endnumber of items to drop from the end of the source sequence count)Returns an Observable that drops a specified number of items from the end of the sequence emitted by the source Observable. |
| public final Observable | Returns: an Observable that drops those items emitted by the source Observable in a time window before the source completes defined bytimethe length of the time window time, TimeUnit the time unit of unit)timeReturns an Observable that drops items emitted by the source Observable during a specified time window before the source completes. |
| public final Observable | Returns: an Observable that drops those items emitted by the source Observable in a time window before the source completes defined bytime and schedulerthe length of the time window time, TimeUnit the time unit of unit, Scheduler timethe scheduler used as the time source scheduler)Returns an Observable that drops items emitted by the source Observable during a specified time window (defined on a specified scheduler) before the source completes. |
| public final < the element type of the other Observable U> Observable | Returns: an Observable that skips items from the source Observable until the second Observable emits an item, then emits the remaining itemsthe second Observable that has to emit an item before the source Observable's elements begin
to be mirrored by the resulting Observable other)Returns an Observable that skips items emitted by the source Observable until a second Observable emits an item. |
| public final Observable | Returns: an Observable that begins emitting items emitted by the source Observable when the specified predicate becomes falsea function to test each item emitted from the source Observable predicate)Returns an Observable that skips all items emitted by the source Observable as long as a specified condition holds true, but emits all further source items as soon as the condition becomes false. |
| public final Observable | Returns: an Observable that emits the items emitted by the source Observable in sorted orderReturns an Observable that emits the events emitted by source Observable, in a sorted order. |
| public final Observable | Returns: an Observable that emits the items emitted by the source Observable in sorted ordera function that compares two items emitted by the source Observable and returns an Integer
that indicates their sort order sortFunction)Returns an Observable that emits the events emitted by source Observable, in a sorted order based on a specified comparison function. |
| public final Observable | Returns: an Observable that emits the items in the specifiedObservable and then emits the items
emitted by the source Observablean Observable that contains the items you want the modified Observable to emit first values)Returns an Observable that emits the items in a specified |
| public final Observable | Returns: an Observable that emits the items in the specifiedIterable and then emits the items
emitted by the source Observablean Iterable that contains the items you want the modified Observable to emit first values)Returns an Observable that emits the items in a specified |
| public final Observable | Returns: an Observable that emits the specified item before it begins to emit items emitted by the source Observablethe item to emit t1)Returns an Observable that emits a specified item before it begins to emit items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits the specified items before it begins to emit items emitted by the source Observablethe first item to emit t1, T the second item to emit t2)Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits the specified items before it begins to emit items emitted by the source Observablethe first item to emit t1, T the second item to emit t2, T the third item to emit t3)Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits the specified items before it begins to emit items emitted by the source Observablethe first item to emit t1, T the second item to emit t2, T the third item to emit t3, T the fourth item to emit t4)Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits the specified items before it begins to emit items emitted by the source Observablethe first item to emit t1, T the second item to emit t2, T the third item to emit t3, T the fourth item to emit t4, T the fifth item to emit t5)Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits the specified items before it begins to emit items emitted by the source Observablethe first item to emit t1, T the second item to emit t2, T the third item to emit t3, T the fourth item to emit t4, T the fifth item to emit t5, T the sixth item to emit t6)Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits the specified items before it begins to emit items emitted by the source Observablethe first item to emit t1, T the second item to emit t2, T the third item to emit t3, T the fourth item to emit t4, T the fifth item to emit t5, T the sixth item to emit t6, T the seventh item to emit t7)Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits the specified items before it begins to emit items emitted by the source Observablethe first item to emit t1, T the second item to emit t2, T the third item to emit t3, T the fourth item to emit t4, T the fifth item to emit t5, T the sixth item to emit t6, T the seventh item to emit t7, T the eighth item to emit t8)Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits the specified items before it begins to emit items emitted by the source Observablethe first item to emit t1, T the second item to emit t2, T the third item to emit t3, T the fourth item to emit t4, T the fifth item to emit t5, T the sixth item to emit t6, T the seventh item to emit t7, T the eighth item to emit t8, T the ninth item to emit t9)Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable. |
| public final Subscription | Returns: aSubscription reference with which the Observer can stop receiving items before
the Observable has finished sending themSubscribes to an Observable and ignores |
| public final Subscription | Returns: aSubscription reference with which the Observer can stop receiving items before
the Observable has finished sending themthe onNext)Action1<T> you have designed to accept emissions from the ObservableSubscribes to an Observable and provides a callback to handle the items it emits. |
| public final Subscription | Returns: aSubscription reference with which the Observer can stop receiving items before
the Observable has finished sending themthe onNext, final Action1<Throwable> Action1<T> you have designed to accept emissions from the Observablethe onError)Action1<Throwable> you have designed to accept any error notification from the
ObservableSubscribes to an Observable and provides callbacks to handle the items it emits and any error notification it issues. |
| public final Subscription | Returns: aSubscription reference with which the Observer can stop receiving items before
the Observable has finished sending themthe onNext, final Action1<Throwable> Action1<T> you have designed to accept emissions from the Observablethe onError, final Action0 Action1<Throwable> you have designed to accept any error notification from the
Observablethe onCompleted)Action0 you have designed to accept a completion notification from the
ObservableSubscribes to an Observable and provides callbacks to handle the items it emits and any error or completion notification it issues. |
| public final Subscription | Returns: aSubscription reference with which the Observer can stop receiving items before
the Observable has completedthe Observer that will handle emissions and notifications from the Observable observer)Subscribes to an Observable and provides an Observer that implements functions to handle the items the Observable emits and any error or completion notification it issues. |
| public final Subscription | Returns: aSubscription reference with which Subscribers that are Observers can
unsubscribe from the Observablethe subscriber)Subscriber that will handle emissions and notifications from the ObservableSubscribes to an Observable and provides a Subscriber that implements functions to handle the items the Observable emits and any error or completion notification it issues. |
| pack-priv static <T> Subscription | |
| public final Observable | Returns: the source Observable modified so that its subscriptions happen on the specifiedSchedulerthe scheduler)Scheduler to perform subscription actions onAsynchronously subscribes Observers to this Observable on the specified |
| public final Observable | Returns: the source Observable modified so that its subscriptions happen on the specifiedSchedulerthe scheduler, boolean Scheduler to perform subscription actions onif true, requests are rerouted to the given Scheduler as well (strong pipelining)
if false, requests coming from any thread are simply forwarded to
the upstream on the same thread (weak pipelining) requestOn)Asynchronously subscribes Observers to this Observable on the specified |
| public final Observable | Returns: an Observable that emits the items emitted by the source Observable or the items of an alternate Observable if the source Observable is empty.the alternate Observable to subscribe to if the source does not emit any items alternate)Returns an Observable that emits the items emitted by the source Observable or the items of an alternate Observable if the source Observable is empty. |
| public final < the element type of the inner Observables and the output R> Observable | Returns: an Observable that emits the items emitted by the Observable returned from applyingfunc to the most recently emitted item emitted by the source Observablea function that, when applied to an item emitted by the source Observable, returns an
Observable func)Returns a new Observable by applying a function that you supply to each item emitted by the source Observable that returns an Observable, and then emitting the items emitted by the most recently emitted of these Observables. |
| public final < the element type of the inner Observables and the output R> Observable | Returns: an Observable that emits the items emitted by the Observable returned from applyingfunc to the most recently emitted item emitted by the source Observablea function that, when applied to an item emitted by the source Observable, returns an
Observable func)Returns a new Observable by applying a function that you supply to each item emitted by the source Observable that returns an Observable, and then emitting the items emitted by the most recently emitted of these Observables and delays any error until all Observables terminate. |
| public static < the item type T> Observable | Returns: an Observable that emits the items emitted by the Observable most recently emitted by the source Observablethe source Observable that emits Observables sequenceOfSequences)Converts an Observable that emits Observables into an Observable that emits the items emitted by the most recently emitted of those Observables. |
| public static < the item type T> Observable | Returns: an Observable that emits the items emitted by the Observable most recently emitted by the source Observablethe source Observable that emits Observables sequenceOfSequences)Converts an Observable that emits Observables into an Observable that emits the items emitted by the most recently emitted of those Observables and delays any exception until all Observables terminate. |
| public final Observable | Returns: an Observable that emits only the firstcount items emitted by the source Observable, or
all of the items from the source Observable if that Observable emits fewer than count itemsthe maximum number of items to emit count)Returns an Observable that emits only the first |
| public final Observable | |
| public final Observable | Returns: an Observable that emits those items emitted by the source Observable before the time runs out, according to the specified Schedulerthe length of the time window time, TimeUnit the time unit of unit, Scheduler timethe Scheduler used for time source scheduler)Returns an Observable that emits those items emitted by source Observable before a specified time (on a specified Scheduler) runs out. |
| public final Observable | Returns: an Observable that emits only the very first item emitted by the source Observable that satisfies the given condition, or that completes without emitting anything if the source Observable completes without emitting a single condition-satisfying itemthe condition any item emitted by the source Observable has to satisfy predicate)Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition. |
| public final Observable | Returns: an Observable that emits at most the lastcount items emitted by the source Observablethe maximum number of items to emit from the end of the sequence of items emitted by the source
Observable count)Returns an Observable that emits at most the last |
| public final Observable | Returns: an Observable that emits at mostcount items from the source Observable that were emitted
in a specified window of time before the Observable completedthe maximum number of items to emit count, long the length of the time window time, TimeUnit the time unit of unit)timeReturns an Observable that emits at most a specified number of items from the source Observable that were emitted in a specified window of time before the Observable completed. |
| public final Observable | Returns: an Observable that emits at mostcount items from the source Observable that were emitted
in a specified window of time before the Observable completed, where the timing information is
provided by the given schedulerthe maximum number of items to emit count, long the length of the time window time, TimeUnit the time unit of unit, Scheduler timethe scheduler)Scheduler that provides the timestamps for the observed itemsReturns an Observable that emits at most a specified number of items from the source Observable that were emitted in a specified window of time before the Observable completed, where the timing information is provided by a given Scheduler. |
| public final Observable | Returns: an Observable that emits the items from the source Observable that were emitted in the window of time before the Observable completed specified bytimethe length of the time window time, TimeUnit the time unit of unit)timeReturns an Observable that emits the items from the source Observable that were emitted in a specified window of time before the Observable completed. |
| public final Observable | Returns: an Observable that emits the items from the source Observable that were emitted in the window of time before the Observable completed specified bytime, where the timing information is
provided by schedulerthe length of the time window time, TimeUnit the time unit of unit, Scheduler timethe Scheduler that provides the timestamps for the Observed items scheduler)Returns an Observable that emits the items from the source Observable that were emitted in a specified window of time before the Observable completed, where the timing information is provided by a specified Scheduler. |
| public final Observable | Returns: an Observable that emits a single list containing at most the lastcount elements emitted by the
source Observablethe maximum number of items to emit in the list count)Returns an Observable that emits a single List containing at most the last |
| public final Observable | Returns: an Observable that emits a single List containing at mostcount items emitted by the
source Observable during the time window defined by time before the source Observable
completedthe maximum number of items to emit count, long the length of the time window time, TimeUnit the time unit of unit)timeReturns an Observable that emits a single List containing at most |
| public final Observable | Returns: an Observable that emits a single List containing at mostcount items emitted by the
source Observable during the time window defined by time before the source Observable
completedthe maximum number of items to emit count, long the length of the time window time, TimeUnit the time unit of unit, Scheduler timethe Scheduler that provides the timestamps for the observed items scheduler)Returns an Observable that emits a single List containing at most |
| public final Observable | Returns: an Observable that emits a single List containing the items emitted by the source Observable during the time window defined bytime before the source Observable completedthe length of the time window time, TimeUnit the time unit of unit)timeReturns an Observable that emits a single List containing those items from the source Observable that were emitted during a specified window of time before the source Observable completed. |
| public final Observable | Returns: an Observable that emits a single List containing the items emitted by the source Observable during the time window defined bytime before the source Observable completed, where the
timing information is provided by schedulerthe length of the time window time, TimeUnit the time unit of unit, Scheduler timethe Scheduler that provides the timestamps for the observed items scheduler)Returns an Observable that emits a single List containing those items from the source Observable that were emitted during a specified window of time before the source Observable completed, where the timing information is provided by the given Scheduler. |
| public final < the type of items emitted by E> Observableother | Returns: an Observable that emits the items emitted by the source Observable until such time asother emits its first itemthe Observable whose first emitted item will cause other)takeUntil to stop emitting items
from the source ObservableReturns an Observable that emits the items emitted by the source Observable until a second Observable emits an item. |
| public final Observable | Returns: an Observable that first emits items emitted by the source Observable, checks the specified condition after each item, and then completes when the condition is satisfied.a function that evaluates an item emitted by the source Observable and returns a Boolean 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. |
| public final Observable | Returns: an Observable that emits the items from the source Observable so long as each item satisfies the condition defined bypredicate, then completesa function that evaluates an item emitted by the source Observable and returns a Boolean predicate)Returns an Observable that emits items emitted by the source Observable so long as each item satisfied a specified condition, and then completes as soon as this condition is not satisfied. |
| public final AssertableSubscriber | Returns: the new AssertableSubscriber instanceCreates a AssertableSubscriber that requests |
| public final AssertableSubscriber | Returns: the new AssertableSubscriber instancethe amount to request from upstream upfront, non-negative (not verified) initialRequestAmount)Creates an AssertableSubscriber with the initial request amount and subscribes it to this Observable. |
| public final Observable | Returns: an Observable that performs the throttle operationtime to wait before emitting another item after emitting the last item windowDuration, TimeUnit the unit of time of unit)windowDurationReturns an Observable that emits only the first item emitted by the source Observable during sequential time windows of a specified duration. |
| public final Observable | Returns: an Observable that performs the throttle operationtime to wait before emitting another item after emitting the last item skipDuration, TimeUnit the unit of time of unit, Scheduler skipDurationthe scheduler)Scheduler to use internally to manage the timers that handle timeout for each
eventReturns an Observable that emits only the first item emitted by the source Observable during sequential time windows of a specified duration, where the windows are managed by a specified Scheduler. |
| public final Observable | Returns: an Observable that performs the throttle operationduration of windows within which the last item emitted by the source Observable will be
emitted intervalDuration, TimeUnit the unit of time of unit)intervalDurationReturns an Observable that emits only the last item emitted by the source Observable during sequential time windows of a specified duration. |
| public final Observable | Returns: an Observable that performs the throttle operationduration of windows within which the last item emitted by the source Observable will be
emitted intervalDuration, TimeUnit the unit of time of unit, Scheduler intervalDurationthe scheduler)Scheduler to use internally to manage the timers that handle timeout for each
eventReturns an Observable that emits only the last item emitted by the source Observable during sequential time windows of a specified duration, where the duration is governed by a specified Scheduler. |
| public final Observable | Returns: an Observable that filters out items that are too quickly followed by newer itemsthe length of the window of time that must pass after the emission of an item from the source
Observable in which that Observable emits no items in order for the item to be emitted by the
resulting Observable timeout, TimeUnit the unit)TimeUnit of timeoutReturns an Observable that only emits those items emitted by the source Observable that are not followed by another emitted item within a specified time window. |
| public final Observable | Returns: an Observable that filters out items that are too quickly followed by newer itemsthe length of the window of time that must pass after the emission of an item from the source
Observable in which that Observable emits no items in order for the item to be emitted by the
resulting Observable timeout, TimeUnit the unit, Scheduler TimeUnit of timeoutthe scheduler)Scheduler to use internally to manage the timers that handle the timeout for each
itemReturns an Observable that only emits those items emitted by the source Observable that are not followed by another emitted item within a specified time window, where the time window is governed by a specified Scheduler. |
| public final Observable | Returns: an Observable that emits time interval information itemsReturns an Observable that emits records of the time interval between consecutive items emitted by the source Observable. |
| public final Observable | Returns: an Observable that emits time interval information itemsthe scheduler)Scheduler used to compute time intervalsReturns an Observable that emits records of the time interval between consecutive items emitted by the source Observable, where this interval is computed on a specified Scheduler. |
| public final < the first timeout value type (ignored) U, the subsequent timeout value type (ignored) V> Observable | Returns: an Observable that mirrors the source Observable, but notifies observers of aTimeoutException if either the first item or any subsequent item doesn't arrive within
the time windows specified by the timeout selectorsa function that returns an Observable that determines the timeout window for the first source
item firstTimeoutSelector, Func1<? super T, ? extends Observable<V>> a function that returns an Observable for each item emitted by the source Observable and that
determines the timeout window in which the subsequent source item must arrive in order to
continue the sequence timeoutSelector)Returns an Observable that mirrors the source Observable, but notifies observers of a
|
| public final < the first timeout value type (ignored) U, the subsequent timeout value type (ignored) V> Observable | Returns: an Observable that mirrors the source Observable, but switches to theother Observable if
either the first item emitted by the source Observable or any subsequent item doesn't arrive
within time windows defined by the timeout selectorsa function that returns an Observable which determines the timeout window for the first source
item firstTimeoutSelector, Func1<? super T, ? extends Observable<V>> a function that returns an Observable for each item emitted by the source Observable and that
determines the timeout window in which the subsequent source item must arrive in order to
continue the sequence timeoutSelector, Observable<? extends T> the fallback Observable to switch to if the source Observable times out other)Returns an Observable that mirrors the source Observable, but switches to a fallback Observable if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables. |
| public final < the timeout value type (ignored) V> Observable | Returns: an Observable that mirrors the source Observable, but notifies observers of aTimeoutException if an item emitted by the source Observable takes longer to arrive than
the time window defined by the selector for the previously emitted itema function that returns an observable for each item emitted by the source
Observable and that determines the timeout window for the subsequent item timeoutSelector)Returns an Observable that mirrors the source Observable, but notifies observers of a
|
| public final < the timeout value type (ignored) V> Observable | Returns: an Observable that mirrors the source Observable, but switches to mirroring a fallback Observable if an item emitted by the source Observable takes longer to arrive than the time window defined by the selector for the previously emitted itema function that returns an Observable, for each item emitted by the source Observable, that
determines the timeout window for the subsequent item timeoutSelector, Observable<? extends T> the fallback Observable to switch to if the source Observable times out other)Returns an Observable that mirrors the source Observable, but that switches to a fallback Observable if an item emitted by the source Observable doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by an Observable that is a function of the previous item. |
| public final Observable | Returns: the source Observable modified to notify observers of aTimeoutException in case of a
timeoutmaximum duration between emitted items before a timeout occurs timeout, TimeUnit the unit of time that applies to the timeUnit)timeout argument.Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item. |
| public final Observable | Returns: the source Observable modified to switch to the fallback Observable in case of a timeoutmaximum duration between items before a timeout occurs timeout, TimeUnit the unit of time that applies to the timeUnit, Observable<? extends T> timeout argumentthe fallback Observable to use in case of a timeout other)Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item. |
| public final Observable | Returns: the source Observable modified so that it will switch to the fallback Observable in case of a timeoutmaximum duration between items before a timeout occurs timeout, TimeUnit the unit of time that applies to the timeUnit, Observable<? extends T> timeout argumentthe Observable to use as the fallback in case of a timeout other, Scheduler the scheduler)Scheduler to run the timeout timers onReturns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item using a specified Scheduler. |
| public final Observable | Returns: the source Observable modified to notify observers of aTimeoutException in case of a
timeoutmaximum duration between items before a timeout occurs timeout, TimeUnit the unit of time that applies to the timeUnit, Scheduler timeout argumentthe Scheduler to run the timeout timers on scheduler)Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item, where this policy is governed on a specified Scheduler. |
| public static Observable | Returns: an Observable that emits a 0L after theinitialDelay and ever increasing numbers after
each period of time thereafterthe initial delay time to wait before emitting the first value of 0L initialDelay, long the period of time between emissions of the subsequent numbers period, TimeUnit the time unit for both unit)initialDelay and period
Deprecated
use
Returns an Observable that emits a interval(long, long, TimeUnit) instead
0L after the initialDelay and ever increasing numbers
after each period of time thereafter.
|
| public static Observable | Returns: an Observable that emits a 0L after theinitialDelay and ever increasing numbers after
each period of time thereafter, while running on the given Schedulerthe initial delay time to wait before emitting the first value of 0L initialDelay, long the period of time between emissions of the subsequent numbers period, TimeUnit the time unit for both unit, Scheduler initialDelay and periodthe Scheduler on which the waiting happens and items are emitted scheduler)
Deprecated
use
Returns an Observable that emits a interval(long, long, TimeUnit, Scheduler) instead
0L after the initialDelay and ever increasing numbers
after each period of time thereafter, on a specified Scheduler.
|
| public static Observable | |
| public static Observable | Returns: an Observable that emits one item after a specified delay, on a specified Scheduler, and then completesthe initial delay before emitting a single 0L delay, TimeUnit time units to use for unit, Scheduler delaythe scheduler)Scheduler to use for scheduling the itemReturns an Observable that emits |
| public final Observable | Returns: an Observable that emits timestamped items from the source ObservableReturns an Observable that emits each item emitted by the source Observable, wrapped in a
|
| public final Observable | Returns: an Observable that emits timestamped items from the source Observable with timestamps provided by theschedulerthe scheduler)Scheduler to use as a time sourceReturns an Observable that emits each item emitted by the source Observable, wrapped in a
|
| public final < the resulting object type R> R | Returns: the value returned by the functionthe function that receives the current Observable instance and returns a value converter)Calls the specified converter function during assembly time and returns its resulting value. |
| public final BlockingObservable | Returns: aBlockingObservable version of this ObservableConverts an Observable into a |
| public Completable | Returns: a Completable that calls onCompleted on it's subscriber when the source Observable calls onCompletedReturns a Completable that discards all onNext emissions (similar to
|
| public final Observable | Returns: an Observable that emits a single item: a List containing all of the items emitted by the source ObservableReturns an Observable that emits a single item, a list composed of all the items emitted by the source Observable. |
| public final < the key type of the Map K> Observable | Returns: an Observable that emits a single item: a HashMap containing the mapped items from the source Observablethe function that extracts the key from a source item to be used in the HashMap keySelector)Returns an Observable that emits a single HashMap containing all items emitted by the source Observable,
mapped by the keys returned by a specified |
| public final < the key type of the Map K, the value type of the Map V> Observable | Returns: an Observable that emits a single item: a HashMap containing the mapped items from the source Observablethe function that extracts the key from a source item to be used in the HashMap keySelector, Func1<? super T, ? extends V> the function that extracts the value from a source item to be used in the HashMap valueSelector)Returns an Observable that emits a single HashMap containing values corresponding to items emitted by the
source Observable, mapped by the keys returned by a specified |
| public final < the key type of the Map K, the value type of the Map V> Observable | Returns: an Observable that emits a single item: a Map that contains the mapped items emitted by the source Observablethe function that extracts the key from a source item to be used in the Map keySelector, Func1<? super T, ? extends V> the function that extracts the value from the source items to be used as value in the Map valueSelector, Func0<? extends Map<K, V>> the function that returns a Map instance to be used mapFactory)Returns an Observable that emits a single Map, returned by a specified |
| public final < the key type of the Map K> Observable | Returns: an Observable that emits a single item: a HashMap that contains an ArrayList of items mapped from the source Observablethe function that extracts the key from the source items to be used as key in the HashMap keySelector)Returns an Observable that emits a single HashMap that contains an ArrayList of items emitted by the
source Observable keyed by a specified |
| public final < the key type of the Map K, the value type of the Map V> Observable | Returns: an Observable that emits a single item: a HashMap that contains an ArrayList of items mapped from the source Observablethe function that extracts a key from the source items to be used as key in the HashMap keySelector, Func1<? super T, ? extends V> the function that extracts a value from the source items to be used as value in the HashMap valueSelector)Returns an Observable that emits a single HashMap that contains an ArrayList of values extracted by a
specified |
| public final < the key type of the Map K, the value type of the Map V> Observable | Returns: an Observable that emits a single item: a Map that contains a list items mapped from the source Observablethe function that extracts a key from the source items to be used as the key in the Map keySelector, Func1<? super T, ? extends V> the function that extracts a value from the source items to be used as the value in the Map valueSelector, Func0<? extends Map<K, Collection<V>>> the function that returns a Map instance to be used mapFactory)Returns an Observable that emits a single Map, returned by a specified |
| public final < the key type of the Map K, the value type of the Map V> Observable | Returns: an Observable that emits a single item: a Map that contains the collection of mapped items from the source Observablethe function that extracts a key from the source items to be used as the key in the Map keySelector, Func1<? super T, ? extends V> the function that extracts a value from the source items to be used as the value in the Map valueSelector, Func0<? extends Map<K, Collection<V>>> the function that returns a Map instance to be used mapFactory, Func1<? super K, ? extends Collection<V>> the function that returns a Collection instance for a particular key to be used in the Map collectionFactory)Returns an Observable that emits a single Map, returned by a specified |
| public Single | Returns: a Single that emits the single item emitted by the source ObservableReturns a Single that emits the single item emitted by the source Observable, if that Observable emits only a single item. |
| public final Observable | Returns: an Observable that emits a list that contains the items emitted by the source Observable in sorted orderReturns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order. |
| public final Observable | Returns: an Observable that emits a list that contains the items emitted by the source Observable in sorted ordera function that compares two items emitted by the source Observable and returns an Integer
that indicates their sort order sortFunction)Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order based on a specified comparison function. |
| public final Observable | Returns: an Observable that emits a list that contains the items emitted by the source Observable in sorted orderthe initial capacity of the ArrayList used to accumulate items before sorting initialCapacity)Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order. |
| public final Observable | Returns: an Observable that emits a list that contains the items emitted by the source Observable in sorted ordera function that compares two items emitted by the source Observable and returns an Integer
that indicates their sort order sortFunction, int the initial capacity of the ArrayList used to accumulate items before sorting initialCapacity)Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order based on a specified comparison function. |
| public static < the type of the items that this Observable emits T> Observable | Returns: an Observable that, when aSubscriber subscribes to it, will execute the specified
functiona function that accepts an fSubscriber<T>, and invokes its onNext,
onError, and onCompleted methods as appropriateReturns an Observable that executes the given OnSubscribe action for each individual Subscriber that subscribes; unsubscription and backpressure must be implemented manually. |
| public final Subscription | Returns: aSubscription reference with which the Subscriber can stop receiving items
before the Observable has completedthe Subscriber that will handle emissions and notifications from the Observable subscriber)Subscribes to an Observable and invokes |
| public final Observable | Returns: the source Observable modified so that its unsubscriptions happen on the specifiedSchedulerthe scheduler)Scheduler to perform unsubscription actions onModifies the source Observable so that subscribers will unsubscribe from it on a specified
|
| public static < the element type of the generated Observable T, the type of the resource associated with the output sequence Resource> Observable | Returns: the Observable whose lifetime controls the lifetime of the dependent resource objectthe factory function to create a resource object that depends on the Observable resourceFactory, final Func1<? super Resource, ? extends Observable<? extends T>> the factory function to create an Observable observableFactory, final Action1<? super Resource> the function that will dispose of the resource disposeAction)Constructs an Observable that creates a dependent resource object which is disposed of on unsubscription. |
| public static < the element type of the generated Observable T, the type of the resource associated with the output sequence Resource> Observable | Returns: the Observable whose lifetime controls the lifetime of the dependent resource objectthe factory function to create a resource object that depends on the Observable resourceFactory, final Func1<? super Resource, ? extends Observable<? extends T>> the factory function to create an Observable observableFactory, final Action1<? super Resource> the function that will dispose of the resource disposeAction, boolean if disposeEagerly)true then disposal will happen either on unsubscription or just before emission of
a terminal event (onComplete or onError).Constructs an Observable that creates a dependent resource object which is disposed of just before
termination if you have set |
| public final < the element type of the boundary Observable TClosing> Observable | Returns: an Observable that emits connected, non-overlapping windows of items from the source Observable wheneverclosingSelector emits an itema closingSelector)Func0 that returns an Observable that governs the boundary between windows.
When the source Observable emits an item, window emits the current window and begins
a new one.Returns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping windows, each containing at mostcount items from the source Observablethe maximum size of each window before it should be emitted count)Returns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits windows everyskip items containing at most count items
from the source Observablethe maximum size of each window before it should be emitted count, int how many items need to be skipped before starting a new window. Note that if skip)skip and
count are equal this is the same operation as window(int).Returns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits new windows periodically as a fixed timespan elapsesthe period of time each window collects items before it should be emitted timespan, long the period of time after which a new window will be created timeshift, TimeUnit the unit of time that applies to the unit)timespan and timeshift argumentsReturns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits new windows periodically as a fixed timespan elapsesthe period of time each window collects items before it should be emitted timespan, long the period of time after which a new window will be created timeshift, TimeUnit the unit of time that applies to the unit, Scheduler timespan and timeshift argumentsthe scheduler)Scheduler to use when determining the end and start of a windowReturns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits new windows periodically as a fixed timespan elapsesthe period of time each window collects items before it should be emitted timespan, long the period of time after which a new window will be created timeshift, TimeUnit the unit of time that applies to the unit, int timespan and timeshift argumentsthe maximum size of each window before it should be emitted count, Scheduler the scheduler)Scheduler to use when determining the end and start of a windowReturns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping windows representing items emitted by the source Observable during fixed, consecutive durationsthe period of time each window collects items before it should be emitted and replaced with a
new window timespan, TimeUnit the unit of time that applies to the unit)timespan argumentReturns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping windows of items from the source Observable that were emitted during a fixed duration of time or when the window has reached maximum capacity (whichever occurs first)the period of time each window collects items before it should be emitted and replaced with a
new window timespan, TimeUnit the unit of time that applies to the unit, int timespan argumentthe maximum size of each window before it should be emitted count)Returns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping windows of items from the source Observable that were emitted during a fixed duration of time or when the window has reached maximum capacity (whichever occurs first)the period of time each window collects items before it should be emitted and replaced with a
new window timespan, TimeUnit the unit of time which applies to the unit, int timespan argumentthe maximum size of each window before it should be emitted count, Scheduler the scheduler)Scheduler to use when determining the end and start of a windowReturns an Observable that emits windows of items it collects from the source Observable. |
| public final Observable | Returns: an Observable that emits connected, non-overlapping windows containing items emitted by the source Observable within a fixed durationthe period of time each window collects items before it should be emitted and replaced with a
new window timespan, TimeUnit the unit of time which applies to the unit, Scheduler timespan argumentthe scheduler)Scheduler to use when determining the end and start of a windowReturns an Observable that emits windows of items it collects from the source Observable. |
| public final < the element type of the window-opening Observable TOpening, the element type of the window-closing Observables TClosing> Observable | Returns: an Observable that emits windows of items emitted by the source Observable that are governed by the specified window-governing Observablesan Observable that, when it emits an item, causes another window to be created windowOpenings, Func1<? super TOpening, ? extends Observable<? extends TClosing>> a closingSelector)Func1 that produces an Observable for every window created. When this Observable
emits an item, the associated window is closed and emittedReturns an Observable that emits windows of items it collects from the source Observable. |
| public final < the window element type (ignored) U> Observable | Returns: an Observable that emits non-overlapping windows of items it collects from the source Observable where the boundary of each window is determined by the items emitted from theboundary
Observablean Observable whose emitted items close and open windows boundary)Returns an Observable that emits non-overlapping windows of items it collects from the source Observable where the boundary of each window is determined by the items emitted from a specified boundary-governing Observable. |
| public final < the element type of the other Observable U, the result type of the combination R> Observable | Returns: an Observable that merges the specified Observable into this Observable by using theresultSelector function only when the source Observable sequence (this instance) emits an
itemthe other Observable other, Func2<? super T, ? super U, ? extends R> the function to call when this Observable emits an item and the other Observable has already
emitted an item, to generate the item to be emitted by the resulting Observable resultSelector)Merges the specified Observable into this Observable sequence by using the |
| public final < the first other source's value type T1, the second other source's value type T2, the result value type R> Observable | Returns: the new Observable instancethe first other Observable o1, Observable<T2> the second other Observable o2, Func3<? super T, ? super T1, ? super T2, R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public final < the first other source's value type T1, the second other source's value type T2, the third other source's value type T3, the result value type R> Observable | Returns: the new Observable instancethe first other Observable o1, Observable<T2> the second other Observable o2, Observable<T3> the third other Observable o3, Func4<? super T, ? super T1, ? super T2, ? super T3, R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public final < the first other source's value type T1, the second other source's value type T2, the third other source's value type T3, the fourth other source's value type T4, the result value type R> Observable | Returns: the new Observable instancethe first other Observable o1, Observable<T2> the second other Observable o2, Observable<T3> the third other Observable o3, Observable<T4> the fourth other Observable o4, Func5<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public final < the first other source's value type T1, the second other source's value type T2, the third other source's value type T3, the fourth other source's value type T4, the fifth other source's value type T5, the result value type R> Observable | Returns: the new Observable instancethe first other Observable o1, Observable<T2> the second other Observable o2, Observable<T3> the third other Observable o3, Observable<T4> the fourth other Observable o4, Observable<T5> the fifth other Observable o5, Func6<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public final < the first other source's value type T1, the second other source's value type T2, the third other source's value type T3, the fourth other source's value type T4, the fifth other source's value type T5, the sixth other source's value type T6, the result value type R> Observable | Returns: the new Observable instancethe first other Observable o1, Observable<T2> the second other Observable o2, Observable<T3> the third other Observable o3, Observable<T4> the fourth other Observable o4, Observable<T5> the fifth other Observable o5, Observable<T6> the sixth other Observable o6, Func7<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public final < the first other source's value type T1, the second other source's value type T2, the third other source's value type T3, the fourth other source's value type T4, the fifth other source's value type T5, the sixth other source's value type T6, the seventh other source's value type T7, the result value type R> Observable | Returns: the new Observable instancethe first other Observable o1, Observable<T2> the second other Observable o2, Observable<T3> the third other Observable o3, Observable<T4> the fourth other Observable o4, Observable<T5> the fifth other Observable o5, Observable<T6> the sixth other Observable o6, Observable<T7> the seventh other Observable o7, Func8<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public final < the first other source's value type T1, the second other source's value type T2, the third other source's value type T3, the fourth other source's value type T4, the fifth other source's value type T5, the sixth other source's value type T6, the seventh other source's value type T7, the eighth other source's value type T8, the result value type R> Observable | Returns: the new Observable instancethe first other Observable o1, Observable<T2> the second other Observable o2, Observable<T3> the third other Observable o3, Observable<T4> the fourth other Observable o4, Observable<T5> the fifth other Observable o5, Observable<T6> the sixth other Observable o6, Observable<T7> the seventh other Observable o7, Observable<T8> the eighth other Observable o8, Func9<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public final < the result value type R> Observable | Returns: the new Observable instancethe array of other sources others, FuncN<R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public final < the result value type R> Observable | Returns: the new Observable instancethe iterable of other sources others, FuncN<R> the function called with an array of values from each participating observable combiner)Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item. |
| public static < the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsan Iterable of source Observables ws, FuncN<? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)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 Observables. |
| public static < the result type R> Observable | Returns: an Observable that emits the zipped resultsan array of source Observables ws, FuncN<? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)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 Observables. |
| public static < the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsan Observable of source Observables ws, final FuncN<? extends R> a function that, when applied to an item emitted by each of the Observables emitted by
zipFunction)ws, results in an item that will be emitted by the resulting ObservableReturns an Observable that emits the results of a specified combiner function applied to combinations of n items emitted, in sequence, by the n Observables emitted by a specified Observable. |
| public static < the value type of the first source T1, the value type of the second source T2, the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsthe first source Observable o1, Observable<? extends T2> a second source Observable o2, final Func2<? super T1, ? super T2, ? extends R> a function that, when applied to an item emitted by each of the source Observables, results
in an item that will be emitted by the resulting Observable zipFunction)Returns an Observable that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other Observables. |
| public static < the value type of the first source T1, the value type of the second source T2, the value type of the third source T3, the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsthe first source Observable o1, Observable<? extends T2> a second source Observable o2, Observable<? extends T3> a third source Observable o3, Func3<? super T1, ? super T2, ? super T3, ? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)Returns an Observable that emits the results of a specified combiner function applied to combinations of three items emitted, in sequence, by three other Observables. |
| public static < the value type of the first source T1, the value type of the second source T2, the value type of the third source T3, the value type of the fourth source T4, the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsthe first source Observable o1, Observable<? extends T2> a second source Observable o2, Observable<? extends T3> a third source Observable o3, Observable<? extends T4> a fourth source Observable o4, Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)Returns an Observable that emits the results of a specified combiner function applied to combinations of four items emitted, in sequence, by four other Observables. |
| public static < the value type of the first source T1, the value type of the second source T2, the value type of the third source T3, the value type of the fourth source T4, the value type of the fifth source T5, the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsthe first source Observable o1, Observable<? extends T2> a second source Observable o2, Observable<? extends T3> a third source Observable o3, Observable<? extends T4> a fourth source Observable o4, Observable<? extends T5> a fifth source Observable o5, Func5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)Returns an Observable that emits the results of a specified combiner function applied to combinations of five items emitted, in sequence, by five other Observables. |
| public static < the value type of the first source T1, the value type of the second source T2, the value type of the third source T3, the value type of the fourth source T4, the value type of the fifth source T5, the value type of the sixth source T6, the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsthe first source Observable o1, Observable<? extends T2> a second source Observable o2, Observable<? extends T3> a third source Observable o3, Observable<? extends T4> a fourth source Observable o4, Observable<? extends T5> a fifth source Observable o5, Observable<? extends T6> a sixth source Observable o6, Func6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)Returns an Observable that emits the results of a specified combiner function applied to combinations of six items emitted, in sequence, by six other Observables. |
| public static < the value type of the first source T1, the value type of the second source T2, the value type of the third source T3, the value type of the fourth source T4, the value type of the fifth source T5, the value type of the sixth source T6, the value type of the seventh source T7, the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsthe first source Observable o1, Observable<? extends T2> a second source Observable o2, Observable<? extends T3> a third source Observable o3, Observable<? extends T4> a fourth source Observable o4, Observable<? extends T5> a fifth source Observable o5, Observable<? extends T6> a sixth source Observable o6, Observable<? extends T7> a seventh source Observable o7, Func7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)Returns an Observable that emits the results of a specified combiner function applied to combinations of seven items emitted, in sequence, by seven other Observables. |
| public static < the value type of the first source T1, the value type of the second source T2, the value type of the third source T3, the value type of the fourth source T4, the value type of the fifth source T5, the value type of the sixth source T6, the value type of the seventh source T7, the value type of the eighth source T8, the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsthe first source Observable o1, Observable<? extends T2> a second source Observable o2, Observable<? extends T3> a third source Observable o3, Observable<? extends T4> a fourth source Observable o4, Observable<? extends T5> a fifth source Observable o5, Observable<? extends T6> a sixth source Observable o6, Observable<? extends T7> a seventh source Observable o7, Observable<? extends T8> an eighth source Observable o8, Func8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)Returns an Observable that emits the results of a specified combiner function applied to combinations of eight items emitted, in sequence, by eight other Observables. |
| public static < the value type of the first source T1, the value type of the second source T2, the value type of the third source T3, the value type of the fourth source T4, the value type of the fifth source T5, the value type of the sixth source T6, the value type of the seventh source T7, the value type of the eighth source T8, the value type of the ninth source T9, the zipped result type R> Observable | Returns: an Observable that emits the zipped resultsthe first source Observable o1, Observable<? extends T2> a second source Observable o2, Observable<? extends T3> a third source Observable o3, Observable<? extends T4> a fourth source Observable o4, Observable<? extends T5> a fifth source Observable o5, Observable<? extends T6> a sixth source Observable o6, Observable<? extends T7> a seventh source Observable o7, Observable<? extends T8> an eighth source Observable o8, Observable<? extends T9> a ninth source Observable o9, Func9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> a function that, when applied to an item emitted by each of the source Observables, results in
an item that will be emitted by the resulting Observable zipFunction)Returns an Observable that emits the results of a specified combiner function applied to combinations of nine items emitted, in sequence, by nine other Observables. |
| public final < the type of items in the T2, other Iterablethe type of items emitted by the resulting Observable R> Observable | Returns: an Observable that pairs up values from the source Observable and theother Iterable
sequence and emits the results of zipFunction applied to these pairsthe Iterable sequence other, Func2<? super T, ? super T2, ? extends R> a function that combines the pairs of items from the Observable and the Iterable to generate
the items to be emitted by the resulting Observable zipFunction)Returns an Observable that emits items that are the result of applying a specified function to pairs of values, one each from the source Observable and a specified Iterable sequence. |
| public final < the type of items emitted by the T2, other Observablethe type of items emitted by the resulting Observable R> Observable | Returns: an Observable that pairs up values from the source Observable and theother Observable
and emits the results of zipFunction applied to these pairsthe other Observable other, Func2<? super T, ? super T2, ? extends R> a function that combines the pairs of items from the two Observables to generate the items to
be emitted by the resulting Observable zipFunction)Returns an Observable that emits items that are the result of applying a specified function to pairs of values, one each from the source Observable and another specified Observable. |