RxJava2 / RxAndroid2操作符distinct去重-低调大师

RxJava2 / RxAndroid2操作符distinct去重

2017-05-17 734

RxJava2 / RxAndroid2操作符distinct去重

distinct去除重复的数据，例如：

package zhangphil.app;

import android.os.Bundle;
import android.support.annotation.Nullable;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;

import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.observers.DisposableObserver;
import io.reactivex.schedulers.Schedulers;

public class MainActivity extends AppCompatActivity {
    private final String TAG = getClass().getSimpleName();

    private CompositeDisposable mCompositeDisposable = new CompositeDisposable();

    private Integer[] test_data = {
            1, 2, 2, 3, 4, 5, 5, 6, 7, 7, 8, 9
    }; //故意设置若干重复的数据，等待去重复数据

    @Override
    public void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        test();
    }

    private void test() {
        DisposableObserver disposableObserver = new DisposableObserver<Integer>() {
            @Override
            public void onNext(Integer i) {
                Log.d(TAG, "#####开始#####");
                Log.d("数据", String.valueOf(i));
                Log.d(TAG, "#####结束#####");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "onComplete");
            }

            @Override
            public void onError(Throwable e) {
                Log.e(TAG, e.toString(), e);
            }
        };

        Observable<Integer> observable = Observable.fromArray(test_data);

        mCompositeDisposable.add(observable
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .distinct()
                .subscribeWith(disposableObserver));
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();

        // 如果退出程序，就清除后台任务
        mCompositeDisposable.clear();
    }
}

代码输出：

05-18 10:19:32.361 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.361 2346-2346/zhangphil.app D/数据: 1
05-18 10:19:32.361 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 2
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 3
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 4
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 5
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 6
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 7
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 8
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 9
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束#####
05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: onComplete

微信关注我们

原文链接：https://yq.aliyun.com/articles/615867

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Google 最新的 Fuchsia OS【科技讯息摘要】

转自：http://www.cnblogs.com/pied/p/5771782.html 就是看到篇报道，有点好奇，就去FQ挖了点东西回来。我似乎已开始就抓到了重点，没错，就是 LK 。 LK 是Travis Geiselbrecht 写的一个针对 ARM 的嵌入式操作系统，开源的。点击到它的->Github。从作者的 ->个人主页看，他是早期 iOS 开发者？而且好像在 google 也待蛮久了。 Magenta （Google 还有一个项目也用这个名字，研究机器学习来制作音乐的）是从 LK 出发，提供多进程、安全空间等支持的，针对大型机（有很多 RAM，接口丰富）的内核。然后， LK for embedded + Magenta 就是报道里提到的 Fuchisa OS 系统了。不过，粗略看了下，LK 似乎是已经有过应用案例了，代码仓库里还提供了在 qemu 下虚拟运行该系统的解决方案。但是 Magenta 估计也就处在粗略可用的状态，比如，可能有开发人员写过它的贪吃蛇游戏了。不过，Magenta 的提交貌似挺频繁的，最近的提交都来自 Brian Swetland...

2017-05-17

745

RxJava2 / RxAndroid2操作符ofType：根据类型选择输出结果例如： package zhangphil.app; import android.os.Bundle; import android.support.annotation.Nullable; import android.support.v7.app.AppCompatActivity; import android.util.Log; import io.reactivex.Observable; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.disposables.CompositeDisposable; import io.reactivex.observers.DisposableObserver; import io.reactivex.schedulers.Schedulers; public class MainActivity extends AppCompatActivity ...

2017-05-17

647

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。