偷偷摘套内射激情视频,久久精品99国产国产精,中文字幕无线乱码人妻,中文在线中文a,性爽19p

最適合使用RxJava處理的四種場景

新聞 移動開發(fā)
RxJava是非常熱門的函數(shù)響應(yīng)式編程庫,在Android開發(fā)中已經(jīng)非常流行了,剛開始上手會有點難,但只要理解了它,就再也回不去了。

RxJava是非常熱門的函數(shù)響應(yīng)式編程庫,在Android開發(fā)中已經(jīng)非常流行了,剛開始上手會有點難,但只要理解了它,就再也回不去了;不使用RxJava寫異步請求的話,就感覺各種不爽。

[[201947]]

本文不準(zhǔn)備講RxJava的基礎(chǔ)知識,如果你對RxJava不熟悉,這里有篇不錯的教程可以參考 《給 Android 開發(fā)者的 RxJava 詳解》 。

下面我們開始介紹RxJava最適合使用的四種場景,代碼示例基于RxJava1

場景一: 單請求異步處理

由于在Android UI線程中不能做一些耗時操作,比如網(wǎng)絡(luò)請求,大文件保存等,所以在開發(fā)中經(jīng)常會碰到異步處理的情況,我們最典型的使用場景是RxJava+Retrofit處理網(wǎng)絡(luò)請求

MyService myService = retrofit.create(MyService.class);
myService.getSomething()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(this::updateUI, this::showError);

為了使代碼看起來簡潔點,這邊還使用了lambda表達式, updateUI 和 showError 需要在當(dāng)前類中實現(xiàn),比如:

public void updateUI(Data data){
      //TODO something
}

public void showError(throwable t){
      //show error msg
}

場景二: 多異步請求連續(xù)調(diào)用

這種場景其實也很常見,我們做用戶頭像編輯的使用,一般就會有三個請求需要連續(xù)調(diào)用:

  1. 請求頭像上傳的地址
  2. 上傳頭像
  3. 更新用戶信息

在平時的代碼里,我們需要一步步callback嵌套下來,代碼冗長太難看,而且不好維護,使用RxJava鏈?zhǔn)秸{(diào)用處理代碼邏輯就會非常清晰

Observable.just(1)
  .map(this::task1)
  .map(this::task2)
  .map(this::task3)
  .subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .subscribe(this::updateUI, this::showError);

這里的just發(fā)送的固定值1,沒有實際意義,只是我覺得這樣更信息

你也可以用Observable.create創(chuàng)建observable。

場景三: 多異步請求合并處理

有時候在項目中,我們會碰到組合多個請求的結(jié)果后,再更新UI的情況,比如我們項目中就有一個從多個請求地址獲取通知數(shù)據(jù),然后在APP上再按時間順序組合后展示的需求,這時候我們就可以用RxJava的zip函數(shù)來處理了

MyService myService = retrofit.create(MyService.class);
Observable o1 = myService.getNotification1();
Observable o2 = myService.getNotification2();
Observable.zip(o1,o2, this::combiNotification)
             .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(this::updateUI, this::showError);


public List<Notification> combiNotification(List<Notification> n1, List<Notification> n2){
      //TODO 合并通知列表
}

zip函數(shù)會等待兩個請求都完成后,調(diào)用我們的合并方法combiNotification,等合并處理后再回調(diào)subscribe中的方法。

場景四: 定時輪詢

RxJava還特別適合對定時輪詢?nèi)蝿?wù)的處理, 一種典型的例子就是APP提交了一個任務(wù)給后臺異步處理,假設(shè)后臺處理需要1-2分鐘左右,我們需要定時到后臺查詢進度,并更新到UI上, 傳統(tǒng)的做法是用Handler的postDelay方法,用RxJava實現(xiàn)的話就會非常簡潔

Subscription subscription =  Observable.interval(2, TimeUnit.SECONDS)
                .map(this::getProgress)
                .takeUntil(progress -> progress !=  100)
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<Long>() {
                    @Override
                    public void onCompleted() {
                        //TODO finished
                    }

                    @Override
                    public void onError(Throwable e) {
                    }

                    @Override
                    public void onNext(int progress) {
                         //TODO update progress
                    }
                });

我們以定時2秒查詢一次,直到進度progress=100為止,自動終止輪詢。

以上各種RxJava方法都是異步耗時調(diào)用,考慮到Activity的退出時請求還沒有完成,我們需要在Activity的OnDestroy方法中取消RxJava調(diào)用

subscription.unsubscribe();
責(zé)任編輯:張燕妮 來源: 推酷
相關(guān)推薦

2020-11-24 05:59:41

容器

2020-03-17 15:55:12

Redis數(shù)據(jù)庫命令

2017-04-07 11:30:04

人工智能開發(fā)編程語言

2018-09-07 06:30:50

物聯(lián)網(wǎng)平臺物聯(lián)網(wǎng)IOT

2021-02-14 10:09:04

數(shù)據(jù)目錄數(shù)據(jù)元數(shù)據(jù)

2016-01-26 09:58:28

云存儲云服務(wù)云安全

2018-09-25 07:08:52

IAM身份及訪問管理網(wǎng)絡(luò)安全

2009-07-16 10:53:11

iBATIS 使用

2009-01-19 16:54:50

數(shù)據(jù)挖掘CRM孤立點

2020-06-24 07:49:13

Kubernetes場景網(wǎng)絡(luò)

2016-07-14 16:27:54

linux

2012-12-13 21:50:43

2020-11-10 10:08:41

Kubernetes容器開發(fā)

2014-08-19 15:05:08

Linux

2018-07-16 08:50:31

固態(tài)硬盤內(nèi)存

2024-05-15 08:49:23

.NET定時器UI線程

2018-01-05 08:53:32

LinuxUbuntu發(fā)行版

2019-03-10 22:21:47

框架AI開發(fā)

2020-12-31 11:42:23

Linux編程字體代碼

2017-03-09 13:30:13

Linux游戲AMD
點贊
收藏

51CTO技術(shù)棧公眾號