av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

android - 有數據要處理的時候如何使用rxJava進行異步處理數據

瀏覽:76日期:2024-03-01 13:32:19

問題描述

我需要實現下面這段代碼,但是應該是耗時太長放在主界面會卡,所以希望異步處理

JsonReader jsonReader = new JsonReader();cityObject = jsonReader.jsonObject();try { cityArray = cityObject.getJSONArray('city_info'); for (int i=0;i<cityArray.length();i++) {Gson gson = new Gson();JSONObject city = (JSONObject) cityArray.get(i);cityDataList.add(gson.fromJson(city.toString(), CityData.class)); }} catch (JSONException e) { e.printStackTrace();}provinceList = getProvinceList();cityMap = getCityMap();

public class JsonReader { public JSONObject jsonObject(){InputStream inputStream = getClass().getClassLoader().getResourceAsStream('assets/cityList.json');InputStreamReader streamReader = new InputStreamReader(inputStream);BufferedReader reader = new BufferedReader(streamReader);String line;StringBuilder stringBuilder = new StringBuilder();try { while ((line = reader.readLine()) != null) {stringBuilder.append(line); } reader.close(); reader.close(); inputStream.close();} catch (IOException e) { e.printStackTrace();}try { JSONObject cityJson = new JSONObject(stringBuilder.toString()); return cityJson;} catch (JSONException e) { e.printStackTrace();}return null; }}

private List<String> getProvinceList() {List<String> list = new ArrayList<>();for (int i = 0; i < cityDataList.size(); i++) { CityData cityData = cityDataList.get(i); boolean isProvince = false; for (int j = 0; j < list.size(); j++) {if (list.get(j).equals(cityData.getProv())) { isProvince = true; break;} } if (isProvince) continue; else list.add(cityData.getProv());}return list; } private HashMap<String, List<String>> getCityMap() {HashMap<String, List<String>> map = new HashMap<>();for (int i = 0; i < provinceList.size(); i++) { String prov = provinceList.get(i); List<String> list = new ArrayList<>(); for (int j = 0; j < cityDataList.size(); j++) {if (cityDataList.get(j).getProv().equals(prov)) list.add(cityDataList.get(j).getCity()); } map.put(prov, list);}return map; }

這幾個操作循環比較多,比較耗時,我想用rxjava處理,但是對observable的使用還是不太清楚,有人能介紹一下像我這樣observable怎么寫嗎?我想要改進的是用observable通過flatmap等這些操作符來返回provinceList和cityMap,并且把線程轉到后臺,在前臺接收到這兩個數據就好了

問題解答

回答1:

幫樓主寫了下示例代碼,像樓主這種需求,其實無須操作符進行變換的。

Observable.create(new Observable.OnSubscribe<Pair>() { @Override public void call(Subscriber<? super Pair> subscriber) {JsonReader jsonReader = new JsonReader();cityObject = jsonReader.jsonObject();try { cityArray = cityObject.getJSONArray('city_info'); for (int i=0;i<cityArray.length();i++) {Gson gson = new Gson();JSONObject city = (JSONObject) cityArray.get(i);cityDataList.add(gson.fromJson(city.toString(), CityData.class)); }} catch (JSONException e) { e.printStackTrace();}provinceList = getProvinceList();cityMap = getCityMap();Pair pair = new Pair(provinceList, cityMap); }}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Subscriber<Pair>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(Pair pair) {//pair.first -> provinceList//pair.second -> cityMap }});回答2:

你需要的是cityDataList這個list吧?那么就可以使用Observable.create來新建一個Observable,把所有操作放在OnSubscribe對象中的call方法中,在最后數據準備完成后調用subscriber相應的onNext就行了。同時處理一下對應的onCompleted和onError

標簽: java
相關文章:
主站蜘蛛池模板: 亚洲高清成人 | 欧美xxxⅹ性欧美大片 | 理论片87福利理论电影 | 亚洲福利在线观看 | 国产精品久久久久久久久 | 国产午夜精品一区二区三区嫩草 | 国户精品久久久久久久久久久不卡 | 精品亚洲永久免费精品 | www.成人.com| 日韩精品 电影一区 亚洲 | 久久91精品国产一区二区 | 亚洲综合二区 | 国产96色在线 | 国产一区电影 | 在线观看国产 | 日韩一区二区不卡 | 波霸ol一区二区 | 亚洲视频区 | 国产电影一区二区 | 日韩精品在线观看视频 | 91精品国产综合久久久久久 | 国产高清视频 | 亚洲精品福利在线 | 亚洲社区在线 | 91精品国产91久久久久久最新 | 我想看一级黄色毛片 | 久久不射电影网 | 国内精品久久精品 | 日日夜夜免费精品 | 欧美精品一区二区三区在线播放 | 超碰人人插 | 91av在线视频观看 | 国产精品日韩一区二区 | 日韩精品一区二区三区视频播放 | 国产精品久久久久一区二区 | 国产精品99久 | 亚洲国产日韩欧美 | 狠狠色狠狠色综合系列 | 成人免费毛片在线观看 | 日韩精品免费在线观看 | 国产精品成人一区 |