进阶之光》"/>
《Android进阶之光》
No1:
RxJava使用
dependencies{compile 'io.reactivex:rxjava:1.2.0'compile 'io.reactivex:rxandroid:1.2.1' }
1)创建Observer(观察者)
Subscriber subscriber = new Subscriber<String>(){@Overridepublic void onCompleted(){Log.d(TAG,"onCompleted");}@Overridepublic void onError(Throwable e){Log.d(TAG,"onError");}@Overridepublic void onNext(String s){Log.d(TAG,"onNext"+s);}@Overridepublic void onStart(){Log.d(TAG,"onStart");} }
或者
Observer<String> observer = new Observer<String>(){@Overridepublic void onCompleted(){Log.d(TAG,"onCompleted");}@Overridepublic void onError(Throwable e){Log.d(TAG,"onError");}@Overridepublic void onNext(String s){Log.d(TAG,"onNext"+s);} }
2)创建Observable(被观察者)
Observable observable = Observable.create(new Observable.OnSubscribe<String>){@Overridepublic void call(Subscriber<? super String> subscriber){subscriber.onNext("杨影枫");subscriber.onNext("月媚儿");subscriber.onCompleted();} } //或者 Observable observable = Observable.just("杨影枫","月媚儿"); //或者 String[] words = {"杨影枫","月媚儿"}; Observable observable = Observable.from(words);
3)Subscribe(订阅)
observable.subscribe(subscriber);
No2:
RxJava的Subject
可以理解为Subject=Observal+Observer
1)PublishSubject:PublishSubject只会把在订阅发生的时间点之后来自原始Observable的数据发射给观察者
2)BehaviorSubject:当Observer订阅BehaviorSubject时,它开始发射原始Observable最近发射的数据
3)ReplaySubject:不管Observer何时订阅ReplaySubject,ReplaySubject均会发射所有来自原始Observable的数据给Observer
4)AsyncSubject:当Observable完成时,AsyncSubject只会发射来自原始Observable的最后一个数据
No3:
创建操作符:
1)interval:创建一个按固定时间间隔发射整数序列的Observable,相当于定时器
2)range:创建发射指定范围的整数序列的Observable,可以拿来替代for循环,发射一个范围内的有序整数序列
3)repeat:创建一个N次重复发射特定数据的Observable
变换操作符:
1)map:通过指定一个Func对象,将Observable转换为一个新的Observable对象并发射,观察者将收到新的Observable处理
2)flatmap:将Observable发射的数据集合变换为Observable集合,然后将这些Observable发射的数据平坦化地放进一个单独的Observable
3)cast:cast操作符的作用是强制将Observable发射的所有数据转换为指定类型
4)concatMap:和flatMap使用方法类似
5)flatMapIterable:可以将数据包装成Iterable,在Iterable中我们就可以对数据进行处理了
6)buffer:将源Observable变换为一个新的Observable,这个新的Observable每次发射一组列表值而不是一个一个发射
7)groupBy:用于分组元素,将源Observable变换成一个发射Observable的新Observable(分组后的)
过滤操作符:
1)filter:对源Observable产生的结果自定义规则进行过滤,只有满足条件的结果才会提交给订阅者
2)elementAt:用来返回指定位置的数据
3)distinct:用来去重,其只允许还没有发射过的数据项通过
4)skip:将源Observable发射的数据过滤掉前n项
5)take:只取前n项
6)ignoreElements:忽略所有源Observable产生的结果,只把Observable的onCompleted和onError事件通知给订阅者
7)throttleFirst:会定期发射这个时间段里源Observable发射的第一个数据,throttleFirst操作符默认在computation调度器上执行
8)throttleWithTimeOut:通过时间来限流。源Observable每次发射出来的一个数据后就会进行计时。如果在设定好的时间结束前源Observable有新的数据发射出来,这个数据就会被丢弃,同时throttleWithTimeOut重新开始计时。
组合操作符:
1)startWith:会在源Observable发射的数据前面插上一些数据
2)merge:将多个Observable合并到一个Observable中进行发射,merge可能会让合并的Observable发射的数据交错
3)concat:将多个Observable发射的数据进行合并发射。concat严格按照顺序发射数据,前一个Observable没发射完成时不会发射后一个Observable的数据的
4)zip:合并两个或者多个Observable发射出的数据项,根据指定的函数变换它们,并发射一个新值
5)combineLastest:当两个Observable中的任何一个发射了数据时,使用一个函数结合每个Observable发射的最近数据项,并且基于这个函数的结果发射数据
辅助操作符:
1)delay:让原始Observable在发射每项数据之前都暂停一段指定的时间段
2)Do系列操作符:包括doOnEach、doOnNext、doOnSubscribe、doOnCompleted、doOnError、doOnTerminate、finallyDo
3)subscribeOn:用于指定Observable自身在哪个线程上运行
4)observeOn:用来指定Observer所运行的线程,也就是发射出的数据在哪个线程上使用。一般会指定在主线程中运行,这样就可以修改UI
5)timeout:如果原始Observable过了指定的一段时长没有发射任何数据,timeout操作符会以一个onError通知终止这个Observable,或者继续执行一个备用的Observable。
错误处理操作符:
1)catch:拦截原始Observable的onError通知,将它替换为其他数据项或者数据序列,让产生的Observable能够正常终止或者根本不终止。包括onErrorReturn、onErrorResumeNext、onExceptionResumeNext
2)retry:不会将原始Observable的onError通知传递给观察者,它会订阅这个Observable,再给它一次机会无错误地完成其数据序列。
布尔操作符:
1)all:根据一个函数对源Observable发射的所有数据进行判断,最终返回的结果就是这个判断结果。
2)contains:用来判断Observable所发射的数据是否包含某一个数据
3)isEmpty:用来判断源Observable是否发射过数据
条件操作符:
1)amb:对于给定两个或多个Observable,它只发射首先发射数据或通知的那个Observable的所有数据
2)defaultIfEmpty:发射来自原始Observable的数据,如果原始Observable没有发射数据,就发射一个默认数据
转换操作符:
1)toList:将发射多项数据且为每一项数据调用onNext方法的Observable发射的多项数据组合成一个List
2)toSortedList:类似于toList操作符:不同的是,它会对产生的列表排序,默认是自然升序
3)toMap:收集原始Observable发射的所有数据项到一个Map(默认是HashMap),然后发射这个Map
No4:
RxJava线程控制:想切换线程,需要使用Scheduler
1)Scheduler.immediate():直接在当前线程运行,它是timeout、timeInterval和timeStamp操作符的默认调度器
2)Schedulers.newThread():总是启用新线程,并在新线程执行操作
3)Schedulers.io():I/O操作所使用的Scheduler
4)Schedulersputation():计算所使用的Scheduler
5)Schedulers.trampoline():当我们想在当前线程执行一个任务时,并不是立即时,可以用.trampoline()将它入列
6)AndroidSchedulers.mainThread():RxAndroid库中提供的Scheduler,它指定的操作在主线程中运行
No5:
RxJava结合OkHttp访问网络
private Observable<String> getObservable(final String ip){Observable observable = Observable.create(new Observable.OnSubscribe<String>(){@Overridepublic void call(final Subscriber<? super String> subscriber){mOkHttpClient = new OkHttpClient();RequestBody formBody = new FormBody.Builder().add("ip",ip).build();Request request = new Request.Builder().url(".php").post(formBody).build();Call call = mOkHttpClient.newCall(request);call.enqueue(new Callback(){@Overridepublic void onFailure(Call call,IOException e){subscriber.onError(new Exception("error"));}@Overridepublic void onResponse(Call call,Response response) throws IOException{String str = response.body().string();subscriber.onNext(str);subscriber.onCompleted();}});}});return observable; }
private void postAsynHttp(String size){getObservable(size).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Subscriber<String>(){@Overridepublic void onCompleted(){Log.d(TAG,"onCompleted");}@Overridepublic void onError(Throwable e){Log.d(TAG,e.getMessage());}@Overridepublic void onNext(String s){Log.d(TAG,s);Toast.makeText(getApplicationContext(),"请求成功",Toast.LENGTH_SHORT).show();}}); }
No6:
RxJava结合Retrofit访问网络
No7:
RxJava实现RxBus
更多推荐
《Android进阶之光》
发布评论