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

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.
主站蜘蛛池模板: 裕民县| 巴楚县| 襄垣县| 宽甸| 股票| 陇川县| 洪洞县| 方山县| 郁南县| 增城市| 津市市| 平原县| 界首市| 霸州市| 同德县| 洱源县| 宣汉县| 花垣县| 宿松县| 西盟| 昭觉县| 清水河县| 尼勒克县| 平定县| 韶山市| 奎屯市| 临沂市| 长白| 将乐县| 福泉市| 辉南县| 保靖县| 金昌市| 牙克石市| 黄石市| 淳化县| 古交市| 藁城市| 洛南县| 阜新市| 新余市|