forked from ReactiveX/RxJava
-
Notifications
You must be signed in to change notification settings - Fork 0
Creating Observables
David Gross edited this page Jan 12, 2015
·
82 revisions
This page shows methods that create Observables.
-
just( )— convert an object or several objects into an Observable that emits that object or those objects -
from( )— convert an Iterable, a Future, or an Array into an Observable -
repeat( )— create an Observable that emits a particular item or sequence of items repeatedly -
repeatWhen( )— create an Observable that emits a particular item or sequence of items repeatedly, depending on the emissions of a second Observable -
create( )— create an Observable from scratch by means of a function -
defer( )— do not create the Observable until a Subscriber subscribes; create a fresh Observable on each subscription -
range( )— create an Observable that emits a range of sequential integers -
interval( )— create an Observable that emits a sequence of integers spaced by a given time interval -
timer( )— create an Observable that emits a single item after a given delay -
empty( )— create an Observable that emits nothing and then completes -
error( )— create an Observable that emits nothing and then signals an error -
never( )— create an Observable that emits nothing at all
- 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
- Backpressure
- Error Handling
- Plugins
- Schedulers
- Subjects
- The RxJava Android Module
- How to Contribute