文章同步于我的个人站:http://guojian.site
1.observer的subscribe()具备多个重载的方法
public final Disposable subscribe() {}
// 表示观察者不对被观察者发送的事件作出任何响应(但被观察者还是可以继续发送事件)
public final Disposable subscribe(Consumer<? super T> onNext) {}
// 表示观察者只对被观察者发送的Next事件作出响应
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {}
// 表示观察者只对被观察者发送的Next事件 & Error事件作出响应
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {}
// 表示观察者只对被观察者发送的Next事件、Error事件 & Complete事件作出响应
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {}
// 表示观察者只对被观察者发送的Next事件、Error事件 、Complete事件 & onSubscribe事件作出响应
public final void subscribe(Observer<? super T> observer) {}
// 表示观察者对被观察者发送的任何事件都作出响应
2.切断连接采用Disposable.dispose()
,观察者 无法继续 接收 被观察者的事件,但被观察者还是可以继续发送事件
mDisposable.dispose();
3.创建操作符分类如下:
-
基本创建
create()
-
快速创建,
-
just()
:最多发送十个参数 -
fromArray()
:传入一个数组,长度不限制,传入集合必须转为数组,否则当成一个事件 -
fromIterable()
:传入list集合 -
never()
:不发送任何事件 -
empty()
:仅发送Complete
事件,直接通知Observable observable = Observable.empty();
-
error()
:该方法创建的被观察者对象仅发送Error事件,直接通知异常,可以自定义Observable observable2=Observable.error(new RuntimeException())
即观察者接收后会直接调用onError()
-
-
延迟创建
1.定时操作:经过X秒后,自动执行Y操作
2.周期性操作:每隔X秒后,自动执行Y操作-
defer()
:直到有观察者订阅时,才会动态创建被观察者,发送事件- 通过 Observable工厂方法创建被观察者对象(Observable)
- 每次订阅后,都会得到一个刚创建的最新的Observable对象,这可以确保Observable对象里的数据是最新的
``` // 注:此时被观察者对象还没创建 Observable<Integer> observable = Observable.defer(new Callable<ObservableSource<? extends Integer>>() { @Override public ObservableSource<? extends Integer> call() throws Exception { return Observable.just(i); } }); ```
-
timer()
- 快速创建一个被观察者对象(Observable)
- 发送事件的特点:延迟指定时间后,发送1个数值0(long了类型)
- 延迟指定时间后,调用一次onnext(0),一般用于检测
-
interval()
- 快速创建1个被观察者对象(Observable)
- 发送事件的特点:每隔指定时间 就发送 事件
-
intervalRange()
- 每隔指定时间 就发送 事件,可指定发送的数据的数量
-
range()
- 连续发送 1个事件序列,可指定范围
-
网友评论