RxJava系列之二 变换类操作符具体解释1

Posted gccbuaa

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了RxJava系列之二 变换类操作符具体解释1相关的知识,希望对你有一定的参考价值。

1.回想

上一篇文章我们主要介绍了RxJava , RxJava 的Observables和 RxJava的just操作符。以及RxJava一些经常使用的操作。


没看过的抓紧点我去看吧


事实上RxJava有非常多的操作符, 而我们学过的just仅仅是创建类操作符的当中一种。

以后我会陆续介绍其它的创建类操作符。

文章代码地址:https://github.com/jiang111/RxJavaDemo

2. 变换类操作符之map

開始本篇文章的解说:
map操作符的详细使用方法。


map是属于变换操作符。它的作用是对序列的每一项都应用一个函数来变换Observable发射的数据序列(太官方了), 大白话就是你传递一个Observable,然后它返回给你还有一个Observable。

看图:
技术分享

Map操作符对原始Observable发射的每一项数据应用一个你选择的函数,然后返回一个发射这些结果的Observable

RxJava将这个操作符实现为map函数。

这个操作符默认不在不论什么特定的调度器上执行。

给大家举个样例: 每一个模块传递一个url给底层网络请求您框架, 然后底层框架须要将url进行变换, 比方: 加入host。 那么我们就能够通过map来实现。

以下我们就通过map配合Rxandroid 写一个网络请求。在写代码之前请大家在gradle文件里加入 RxAndroid 的jar包 compile ‘io.reactivex:rxandroid:1.0.+’

代码採用了ButterKnife注解。 直接拷贝下来执行可能会报错,请先cloneproject,再执行。

public static final String HOST = "http://blog.csdn.net/";

    @Bind(R.id.first_wb)
    WebView mWb;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_second);
        Observable.just("jys1115/article/details/47428843").map(new Func1<String, String>() {
            @Override
            public String call(String s) {
                return HOST + s;
            }
        }).map(new Func1<String, String>() {
            @Override
            public String call(String s) {
                return doNetTask(s);
            }
        }).subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String s) {
                        mWb.loadDataWithBaseURL(HOST, s, "text/html", "utf-8", null);
                    }
                });
    }

    private String doNetTask(String s) {

        HttpClient client = new DefaultHttpClient();

        HttpGet get = new HttpGet(s);
        String result;
        try {
            HttpResponse response = client.execute(get);

            if (200 == response.getStatusLine().getStatusCode()) {
                result = EntityUtils.toString(response.getEntity(), HTTP.UTF_8);
            } else {
                result = "状态行非200";
            }

        } catch (Exception e1) {
            result = e1.getStackTrace().toString();
        }
        return result;

    }
代码就不用凝视了,非常easy。 代码中用到的Schedulers.newThread()和 AndroidSchedulers.mainThread() 相信大家都懂的, 以后的文章中我也会介绍到。

看结果:
技术分享

好了, map是个好东西啊, 不要激动, 以下还有很多其它的好东西等待着我们去探索呢。

3. 变换类操作符之flatMap

突然, boss又出新需求了。刚刚我们写了个网络请求。 然后拿出全部请求的数据, 如今我们不须要那么多数据, 我们仅仅须要city字段和WD字段(执行过上段代码就知道了), 并且这次我不在仅仅给你一个url了。而是给你多个url, 写吧。

boss永远都是这种。

非常多人就開始想了。 那就写个for循环呗,我们最擅长了。哈哈,。 RxJava为我们提供了更方便的操作。

flatMap()操作符。




flatMap()操作符的作用是将Observable发射的数据集合变换为Observables集合。然后将这些Observable发射的数据平坦化的放进一个单独的Observable,还是太抽象了。

简单说就是将 一个List 或者数组中的每一条数据都 转换成一个 Observable对象。
那我们就開始写代码吧(代码是最好的老师):

public static final String HOST = "http://www.weather.com.cn";
    List<String> values = new ArrayList<>();
    private String TAG = "SecondActivity2";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        values.add("/adat/sk/101010100.html");
        values.add("/adat/sk/101010100.html");
        values.add("/adat/sk/101010100.html");
        values.add("/adat/sk/101010100.html");
        values.add("/adat/sk/101010100.html");

        Observable.just(values).flatMap(new Func1<List<String>, Observable<?>>() {
            @Override
            public Observable<?> call(List<String> strings) {
                return Observable.from(strings);
            }
        }).cast(String.class).map(new Func1<String, String>() {
            @Override
            public String call(String s) {
                return doNetTaskForString(HOST + s); //取出想要的字段,这里我就不取出来了
            }
        }).subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String s) {
                        Log.i(TAG, "value: " + s); 
                    }
                });
    }

    @NonNull
    @Override
    public int getContentView() {
        return R.layout.activity_second2;
    }

    private synchronized String doNetTaskForString(String s) {

        HttpClient client = new DefaultHttpClient();

        Log.i(TAG, "url:" + s);
        HttpGet get = new HttpGet(s);
        String result;
        try {
            HttpResponse response = client.execute(get);
            Log.i(TAG, "state code :" + response.getStatusLine().getStatusCode());
            if (200 == response.getStatusLine().getStatusCode()) {
                result = EntityUtils.toString(response.getEntity(), HTTP.UTF_8);
            } else {
                result = "状态行非200";
            }

        } catch (Exception e1) {
            result = "抛出了异常" + e1.getMessage();
            e1.printStackTrace();
        }
        return result;

    }

结果(这次採取打log的形式):
技术分享

这段代码里我们又用到的新的操作符 cast .


cast的作用就是 在发射之前强制将Observable发射的全部数据转换为指定类型。
看图:
技术分享

4. 总结

好了,我们总结一下今天学习的内容。我们今天又学习了 两个操作符 flatMap cast, 复习了 just from map 操作符。

下次我们将通过几个栗子把 RxJava剩下的变换类的操作符讲完。 敬请期待吧。

文章代码地址:https://github.com/jiang111/RxJavaDemo

欢迎关注我的微信公众号:androidesigner
通过微信扫描二维码就可以关注。
技术分享























以上是关于RxJava系列之二 变换类操作符具体解释1的主要内容,如果未能解决你的问题,请参考以下文章

Android RxJava操作符详解系列: 变换操作符

给 Android 开发人员的 RxJava 具体解释

RxJava系列3(转换操作符)

RxJava操作符(03-变换操作)

RxJava系列4(过滤操作符)

Rxjava2 Observable的布尔操作符详解及实例