RxJava Observable工作原理

Observables 代表数据的来源,而 Observers (Subscribers) 会监听它们。简而言之,一个 Observable 发出信息,然后一个 Subscriber 消费这些项目。

Observable(观察者)

  • 一旦订阅者开始监听,Observable 就会提供数据。

  • Observable 可以发出任意数量的信息。

  • Observable 也可以只发出完成信息而没有项目。

  • Observable 可以成功终止。

  • Observable 可能永远不会终止。例如,一个按钮可以被点击任意次。

  • Observable 可能会在任何时间点抛出错误。

Subscriber(订阅者)

  • Observable 可以有多个订阅者。

  • 当 Observable 发出一个项目时,每个订阅者的 onNext() 方法都会被调用。

  • 当 Observable 完成发射项目时,每个订阅者的 onComplete() 方法都会被调用。

  • 如果 Observable 发出错误,每个订阅者的 onError() 方法都会被调用。

热门文章

优秀文章