官术网_书友最值得收藏!

Subscribers - the Observer interface

The Subscriber from RxKotlin 1.x,  essentially became an Observer in RxKotlin 2.x. There is an Observer interface in RxKotlin 1.x, but Subscriber is what you pass to the subscribe() method, and it implements Observer. However, In RxJava 2.x, Subscriber only exists when talking about Flowables, which we will cover in Chapter 4Introduction to Backpressure and Flowables.

As you can see in the previous examples in this chapter, Observer is an interface with four methods in it—onNext(item:T), onError(error:Throwable), onComplete(), and onSubscribe(d:Disposable). As stated earlier, when we connect Observable to Observer, it looks for these four methods in Observer and calls them. So, the following is a short description of the four methods:

  • onNextObservable calls this method of Observer to pass each of the items one by one.
  • onComplete: When Observable wants to denote, it's done with passing items to the onNext method, and it calls the onComplete method of Observer.
  • onError: When Observable faces any error, it calls the onError method to deal with the error if defined in the Observer, otherwise, it throws the exception.
  • onSubscribe: This method is called whenever a new Observable subscribes to the Observer.
主站蜘蛛池模板: 临汾市| 即墨市| 大竹县| 太仆寺旗| 安塞县| 增城市| 新野县| 绍兴市| 开江县| 集贤县| 工布江达县| 镇远县| 浮山县| 韶关市| 双柏县| 浙江省| 蛟河市| 大冶市| 湟中县| 确山县| 碌曲县| 东丽区| 武川县| 永和县| 屯留县| 五寨县| 黑龙江省| 界首市| 安陆市| 江永县| 通江县| 斗六市| 会宁县| 阿瓦提县| 宾阳县| 德昌县| 商水县| 庆安县| 外汇| 大化| 苍山县|