forked from ReactiveX/RxJava
-
Notifications
You must be signed in to change notification settings - Fork 0
Combining Observables
David Gross edited this page Jan 12, 2015
·
53 revisions
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 Observable -
merge( )
— combine multiple Observables into one -
mergeDelayError( )
— combine multiple Observables into one, allowing error-free Observables to continue before propagating errors -
zip( )
— 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 function -
join( )
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 Observable -
switchOnNext( )
— 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
A Netflix Original Production
Tech Blog | Twitter @NetflixOSS | Twitter @RxJava | Jobs
- Introduction
- Getting Started
- JavaDoc
- How to Use RxJava
- Additional Reading
- The Observable
- Operators (Alphabetical List)
- Async
- Blocking Observable
- Combining
- Conditional & Boolean
- Connectable Observable
- Error Handling
- Filtering
- Mathematical and Aggregate
- Observable Creation
- String
- Transformational
- Utility Operators
- Implementing Custom Operators, previous
- Backpressure
- Error Handling
- Plugins
- Schedulers
- Subjects
- The RxJava Android Module
- RxJava 2.0
- How to Contribute