- RxJava - Discussion
- RxJava - Useful Resources
- RxJava - Quick Guide
- RxJava - Windowing
- RxJava - Buffering
- RxJava - From Scheduler
- RxJava - IO Scheduler
- RxJava - Computation Scheduler
- RxJava - NewThread Scheduler
- RxJava - Trampoline Scheduler
- RxJava - Schedulers
- RxJava - AsyncSubject
- RxJava - ReplaySubject
- RxJava - BehaviorSubject
- RxJava - PublishSubject
- RxJava - Subjects
- RxJava - Connectable Operators
- RxJava - Mathematical Operators
- RxJava - Conditional Operators
- RxJava - Utility Operators
- RxJava - Combining Operators
- RxJava - Filtering Operators
- RxJava - Transforming Operators
- RxJava - Creating Operators
- RxJava - Using CompositeDisposable
- RxJava - Completable Observable
- RxJava - MayBe Observable
- RxJava - Single Observable
- RxJava - Creating Observables
- RxJava - How Observable works
- RxJava - Environment Setup
- RxJava - Overview
- RxJava - Home
Selected Reading
- Who is Who
- Computer Glossary
- HR Interview Questions
- Effective Resume Writing
- Questions and Answers
- UPSC IAS Exams Notes
RxJava - How Observable works
Observables represents the sources of data where as Observers (Subscribers) psten to them. In nutshell, an Observable emits items and a Subscriber then consumes these items.
Observable
Observable provides data once subscriber starts pstening.
Observable can emit any number of items.
Observable can emit only signal of completion as well with no item.
Observable can terminate successfully.
Observable may never terminate. e.g. a button can be cpcked any number of times.
Observable may throw error at any point of time.
Subscriber
Observable can have multiple subscribers.
When an Observable emits an item, each subscriber onNext() method gets invoked.
When an Observable finished emitting items, each subscriber onComplete() method gets invoked.
If an Observable emits error, each subscriber onError() method gets invoked.