RxJava 变换操作符Map
生活随笔
收集整理的這篇文章主要介紹了
RxJava 变换操作符Map
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
看下文檔如下
通過對每個項目應(yīng)用函數(shù)來轉(zhuǎn)換Observable發(fā)出的項目
個人理解為轉(zhuǎn)換類型
下面寫一個把int 類型轉(zhuǎn)換為String 類型的demo
Observable.create(new ObservableOnSubscribe<Integer>() {@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) {emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);}}).map(new Function<Integer, String>() {@Overridepublic String apply(Integer integer) {return "使用 Map變換操作符 將事件" + integer + "的參數(shù)從整型" + integer + " 變換成字符串類型" + integer;}}).subscribeOn(Schedulers.io()).subscribe(new Observer<String>() {@Overridepublic void onSubscribe(Disposable d) {Log.d("-----rxjava", "開始采用subscribe連接");}@Overridepublic void onNext(String s) {Log.d("-----rxjava", "對Next事件作出響應(yīng):" + s);}@Overridepublic void onError(Throwable e) {Log.d("-----rxjava", "對Error事件作出響應(yīng)" + e);}@Overridepublic void onComplete() {Log.d("-----rxjava", "對onComplete事件作出響應(yīng)");}});}
?
輸入結(jié)果為:
總結(jié)
以上是生活随笔為你收集整理的RxJava 变换操作符Map的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: RxJava 内置多种用于调度的线程类型
- 下一篇: RxJava repeat,repeat