This section explains operators you can use to combine multiple Observables.
startWith( )
— emit a specified sequence of items before beginning to emit the items from the Observablemerge( )
— combine multiple Observables into onemergeDelayError( )
— combine multiple Observables into one, allowing error-free Observables to continue before propagating errorszip( )
— combine sets of items emitted by two or more Observables together via a specified function and emit items based on the results of this function- (
rxjava-joins
)and( )
,then( )
, andwhen( )
— combine sets of items emitted by two or more Observables by means ofPattern
andPlan
intermediaries combineLatest( )
— when an item is emitted by either of two Observables, combine the latest item emitted by each Observable via a specified function and emit items based on the results of this functionjoin( )
andgroupJoin( )
— combine the items emitted by two Observables whenever one item from one Observable falls within a window of duration specified by an item emitted by the other ObservableswitchOnNext( )
— convert an Observable that emits Observables into a single Observable that emits the items emitted by the most-recently emitted of those Observables
(
rxjava-joins
) — indicates that this operator is currently part of the optionalrxjava-joins
package underrxjava-contrib
and is not included with the standard RxJava set of operators