Rxjava 简明教程

RxJava - How Observable works

Observables 表示数据源，而 Observers (Subscribers) 监听这些数据源。简而言之，Observable 发射项目，Subscriber 然后消耗这些项目。

Observables represents the sources of data where as Observers (Subscribers) listen to them. In nutshell, an Observable emits items and a Subscriber then consumes these items.

Observable

  1. Observable provides data once subscriber starts listening.

  2. Observable can emit any number of items.

  3. Observable can emit only signal of completion as well with no item.

  4. Observable can terminate successfully.

  5. Observable may never terminate. e.g. a button can be clicked any number of times.

  6. Observable may throw error at any point of time.

Subscriber

  1. Observable can have multiple subscribers.

  2. When an Observable emits an item, each subscriber onNext() method gets invoked.

  3. When an Observable finished emitting items, each subscriber onComplete() method gets invoked.

  4. If an Observable emits error, each subscriber onError() method gets invoked.