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

首页 > 代码库 > RxJava系列之二变换类操作符具体解释1

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

2024-10-18 23:38:39 210人阅读

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;

    }