RxJava变换操作符Map使用

Map

map是RxJava中最简单的一个变换操作符了, 它的作用就是对上游发送的每一个事件应用一个函数, 使得每一个事件都按照指定的函数去变化. 用事件图表示如下:

图中map中的函数作用是将圆形事件转换为矩形事件, 从而导致下游接收到的事件就变为了矩形.用代码来表示这个例子就是:

创建一个bean

package tongxunlu.com.myapplication;

/**
 * Created by wangwei on 2018/8/30.
 */

public class TestBean {
    private int userAccountType = -1; //账号类型。1:管理员账号 2:普通账号
    private int roleID = -1;//账号所属角色ID
    private int employeeID = -1;//账号对应的员工ID
    private int businessType = -1;//账号对应的行业类型  1 美发 2足浴 3美容 5美甲
    private String userAccountName;//账号名称
    private int userAccountID = -1;//账号ID
    private String roleName;//角色名称

    public static final int BUS_TYPE_MEIFA = 1;
    public static final int BUS_TYPE_ZUYU = 2;
    public static final int BUS_TYPE_MEIRONG = 3;
    public static final int BUS_TYPE_MEIJIA = 5;


    public int getUserAccountType() {
        return userAccountType;
    }

    public void setUserAccountType(int userAccountType) {
        this.userAccountType = userAccountType;
    }

    public int getRoleID() {
        return roleID;
    }

    public void setRoleID(int roleID) {
        this.roleID = roleID;
    }

    public int getEmployeeID() {
        return employeeID;
    }

    public void setEmployeeID(int employeeID) {
        this.employeeID = employeeID;
    }

    public int getBusinessType() {
        return businessType;
    }

    public void setBusinessType(int businessType) {
        this.businessType = businessType;
    }

    public String getUserAccountName() {
        return userAccountName;
    }

    public void setUserAccountName(String userAccountName) {
        this.userAccountName = userAccountName;
    }

    public int getUserAccountID() {
        return userAccountID;
    }

    public void setUserAccountID(int userAccountID) {
        this.userAccountID = userAccountID;
    }

    public String getRoleName() {
        return roleName;
    }

    public void setRoleName(String roleName) {
        this.roleName = roleName;
    }

    //是否有房态
    public boolean hasRoom() {
        if (businessType == 2) {
            return true;
        }
        return false;
    }

}

本地新建一个字符串


{
  "businessType": 345,
  "employeeID": 0,
  "roleID": 2344,
  "roleName": "我是名字",
  "userAccountID": 4567897,
  "userAccountName": "wangwei",
  "userAccountType": 1
}

读取assert里面的字符串


    //从资源文件中获取分类json
    public static String getAssetsData(String path) {
        String result = "";
        try {
            //获取输入流
            InputStream mAssets = CoreApplication.getInstance().getAssets().open(path);
            //获取文件的字节数
            int lenght = mAssets.available();
            //创建byte数组
            byte[] buffer = new byte[lenght];
            //将文件中的数据写入到字节数组中
            mAssets.read(buffer);
            mAssets.close();
            result = new String(buffer);
            return result;
        } catch (IOException e) {
            e.printStackTrace();
            Log.e("fuck", e.getMessage());
            return result;
        }
    }

通过代码开始订阅

        Observable.create(new ObservableOnSubscribe<String>() {
                    @Override
                    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
                        Log.w(TAG, "Observable--" + Thread.currentThread().getName());
                        emitter.onNext(mUserInfoJson);
                        emitter.onComplete();
                    }
                }).subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread())
                        .map(new Function<String, TestBean>() {
                            @Override
                            public TestBean apply(String userString) throws Exception {
                                Log.w(TAG, "apply--" + Thread.currentThread().getName());
                                Gson gson = new Gson();
                                TestBean currentUseInfo = gson.fromJson(userString, TestBean.class);
                                return currentUseInfo;
                            }
                        }).subscribe(new Consumer<TestBean>() {
                    @Override
                    public void accept(TestBean s) throws Exception {
                        Log.w(TAG, "Observ--" + Thread.currentThread().getName());
                        Log.d(TAG, "accept---" + s.getUserAccountName());
                    }
                });

在上游我们发送的是字符串类型, 而在下游我们接收的是TestBean类型, 中间起转换作用的就是map操作符, 运行结果为:

W/MainActivity: Observable--RxCachedThreadScheduler-1
W/MainActivity: apply--main
W/MainActivity: apply--userString{
                 "businessType": 345,
                 "employeeID": 0,
                 "roleID": 2344,
                 "roleName": "我是名字",
                 "userAccountID": 4567897,
                 "userAccountName": "wangwei",
                 "userAccountType": 1
               }
W/MainActivity: Observ--main
D/MainActivity: accept---wangwei

通过Map, 可以将上游发来的事件转换为任意的类型, 可以是一个Object, 也可以是一个集合, 如此强大的操作符快去试试吧。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 223,277评论 6 521
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 95,487评论 3 400
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 170,114评论 0 366
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 60,367评论 1 300
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 69,352评论 6 398
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 52,919评论 1 314
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 41,328评论 3 426
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 40,278评论 0 277
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 46,808评论 1 321
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,882评论 3 343
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 41,005评论 1 354
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 36,672评论 5 351
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 42,344评论 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,839评论 0 25
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,959评论 1 275
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 49,481评论 3 379
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 46,031评论 2 361

推荐阅读更多精彩内容

  • 第2章 基本语法 2.1 概述 基本句法和变量 语句 JavaScript程序的执行单位为行(line),也就是一...
    悟名先生阅读 4,153评论 0 13
  • 第5章 引用类型(返回首页) 本章内容 使用对象 创建并操作数组 理解基本的JavaScript类型 使用基本类型...
    大学一百阅读 3,241评论 0 4
  • 刚吃完晚餐,静静躺着床上。一首好久不见冒出脑海,好久不见,最近还好嘛? 不曾遇见,或许是我遇见最好的女...
    祎爷阅读 181评论 0 0
  • 8月下旬,慌张又急切地想要牢牢抓住暑假的尾巴,计划再向海边出走一次。恰逢2016里约奥运会中国女排争冠赛,于是决定...
    一缕清风袭来阅读 1,073评论 0 5