RxJava Observer 和 Subscriber

2017-02-07 18:28:21   0  举报





仅支持查看

AI智能生成

RxJava Observer 和 Subscriber 都是用于处理异步事件的接口。Observer 是 RxJava 1.x 版本的观察者接口，而 Subscriber 是 RxJava 2.x 版本的观察者接口。两者的主要区别在于 Subscriber 提供了更多的方法来处理事件，如 onComplete、onError、onNext等。此外，Subscriber 还支持背压控制，可以有效地防止事件队列过长导致的内存溢出问题。总之，Observer 和 Subscriber 都是 RxJava 中非常重要的概念，它们可以帮助我们更好地处理异步事件。

模版推荐

作者其他创作

大纲/内容

<code style="padding: 0px; margin: 0px; font-size: 14.4px; white-space: nowrap; background: rgb(241, 241, 241); border: 1px solid rgb(225, 225, 225); border-radius: 4px; font-family: Courier, "Courier New", monospace; color: rgb(34, 34, 34); text-align: start;">Subscriber</code><span style="color: rgb(34, 34, 34); font-family: "PT Sans", HelveticaNeue, "Helvetica Neue", Helvetica, Arial, "Hiragino Sans GB", "Microsoft YaHei", sans-serif; font-size: 16px; text-align: start;"> 新增</span>onStart()

<span style="color: rgb(34, 34, 34); font-family: Courier, "Courier New", monospace; font-size: 14.4px; text-align: left; white-space: nowrap; background-color: rgb(241, 241, 241);">unsubscribe()</span>

<h5 id="toc_9" style="margin: 1em 0px 0.6em; line-height: 1.35; padding: 0px;"><font color="#000000" face="PT Serif, Georgia, Times New Roman, Times, Songti SC, SimSun, sans-serif"><span style="font-size: 20.4px; letter-spacing: -0.6px;">Observable</span></font></h5><h5 id="toc_9" style="margin: 1em 0px 0.6em; line-height: 1.35; padding: 0px;"><font color="#000000" face="PT Serif, Georgia, Times New Roman, Times, Songti SC, SimSun, sans-serif"><span style="font-size: 20.4px; letter-spacing: -0.6px;">被观察者</span></font></h5>

创建方式

create

<div>Observable observable = Observable.create(new Observable.OnSubscribe<String>() {</div><div>    @Override</div><div>    public void call(Subscriber<? super String> subscriber) {</div><div>        subscriber.onNext("Hello");</div><div>        subscriber.onNext("Hi");</div><div>        subscriber.onNext("Aloha");</div><div>        subscriber.onCompleted();</div><div>    }</div><div>});</div>

just

Observable observable = Observable.just("Hello", "Hi", "Aloha");

from

<div>String[] words = {"Hello", "Hi", "Aloha"};</div><div>Observable observable = Observable.from(words);</div>

<div>Observer</div><div>观察者</div>

创建

<div>Observer<String> observer = new Observer<String>() {</div><div>    @Override</div><div>    public void onNext(String s) {</div><div>        Log.d(tag, "Item: " + s);</div><div>    }</div><div><br></div><div>    @Override</div><div>    public void onCompleted() {</div><div>        Log.d(tag, "Completed!");</div><div>    }</div><div><br></div><div>    @Override</div><div>    public void onError(Throwable e) {</div><div>        Log.d(tag, "Error!");</div><div>    }</div><div>};</div>

<div>Subscribe </div><div>订阅</div>

<div>observable.subscribe(observer);</div><div>// 或者：</div><div>observable.subscribe(subscriber);</div>