Android响应式编程开发RxAndroid(5):RxJava 2.0的Consumer

简介: Android响应式编程开发RxAndroid(5):RxJava 2.0的ConsumerRxJava 2.0引入的Consumer相当于1.0时候的Action。


Android响应式编程开发RxAndroid(5):RxJava 2.0的Consumer

RxJava 2.0引入的Consumer相当于1.0时候的Action。如果只是想简洁的获得处理结果,则可以使用RxJava 2.0引入到的Consumer。例如:

package zhangphil.app;

import android.app.Activity;
import android.os.Bundle;
import android.util.Log;

import java.util.Arrays;
import java.util.List;

import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.functions.Consumer;
import io.reactivex.functions.Function;
import io.reactivex.observers.DisposableObserver;
import io.reactivex.schedulers.Schedulers;

public class MainActivity extends Activity {

    //假设一个数据源
    private String TAG = "zhangphil测试";
    private Observable mObservable;

    private DisposableObserver<String> mObserver = new DisposableObserver<String>() {

        @Override
        public void onNext(String s) {
            Log.d(TAG, "onNext - Start");
            Log.d(TAG, String.valueOf(s));
            Log.d(TAG, "onNext - End");
        }

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

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

    //如果只是接受处理结果,那么可以用Consumer(消费)
    private Consumer mConsumer = new Consumer<String>() {
        @Override
        public void accept(String s) throws Exception {
            Log.d(TAG, "accept - Start");
            Log.d(TAG, String.valueOf(s));
            Log.d(TAG, "accept - End");
        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        String[] source = {"zhang", "phil", "@", "csdn"};
        List<String> lists = Arrays.asList(source);

        mObservable = Observable
                .just(lists)
                .subscribeOn(Schedulers.io())//执行任务的线程
                .observeOn(AndroidSchedulers.mainThread()) //回调发生的线程
                .flatMap(mFunction);

        //建立订阅关系
        mObservable.subscribe(mConsumer);
        mObservable.subscribe(mObserver);
    }

    // 设置映射函数,实现简单功能:小写转化为大写
    private Function<List<String>, Observable<String>> mFunction = new Function<List<String>, Observable<String>>() {

        @Override
        public Observable<String> apply(List<String> lists) {
            String[] strs = new String[lists.size()];
            for (int i = 0; i < lists.size(); i++) {
                strs[i] = lists.get(i).toUpperCase();
            }
            return Observable.fromArray(strs);
        }
    };
}


代码运行结果如图:

03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: accept - Start
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: ZHANG
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: accept - End
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: accept - Start
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: PHIL
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: accept - End
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: accept - Start
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: @
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: accept - End
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: accept - Start
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: CSDN
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: accept - End
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onNext - Start
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: ZHANG
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onNext - End
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onNext - Start
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: PHIL
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onNext - End
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onNext - Start
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: @
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onNext - End
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onNext - Start
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: CSDN
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onNext - End
03-02 13:53:55.046 31633-31633/zhangphil.app D/zhangphil测试: onComplete


附录:
1,《Android响应式编程RxAndroid(1):简单例程》链接地址:http://blog.csdn.net/zhangphil/article/details/58593782  
2,《Android响应式编程开发RxAndroid(2):简单例程的Android改造 》链接地址:http://blog.csdn.net/zhangphil/article/details/58597372
3,《Android响应式编程开发RxAndroid(3):map》链接地址:http://blog.csdn.net/zhangphil/article/details/59130641
4,《Android响应式编程开发RxAndroid(4):flatMap》链接地址:http://blog.csdn.net/zhangphil/article/details/59483465

相关文章
|
20天前
|
存储 消息中间件 人工智能
【03】AI辅助编程完整的安卓二次商业实战-本地构建运行并且调试-二次开发改注册登陆按钮颜色以及整体资源结构熟悉-优雅草伊凡
【03】AI辅助编程完整的安卓二次商业实战-本地构建运行并且调试-二次开发改注册登陆按钮颜色以及整体资源结构熟悉-优雅草伊凡
56 3
|
17天前
|
开发工具 Android开发
X Android SDK file not found: adb.安卓开发常见问题-Android SDK 缺少 `adb`(Android Debug Bridge)-优雅草卓伊凡
X Android SDK file not found: adb.安卓开发常见问题-Android SDK 缺少 `adb`(Android Debug Bridge)-优雅草卓伊凡
219 11
X Android SDK file not found: adb.安卓开发常见问题-Android SDK 缺少 `adb`(Android Debug Bridge)-优雅草卓伊凡
|
20天前
|
存储 消息中间件 人工智能
【08】AI辅助编程完整的安卓二次商业实战-修改消息聊天框背景色-触发聊天让程序异常终止bug牵涉更多聊天消息发送优化处理-优雅草卓伊凡
【08】AI辅助编程完整的安卓二次商业实战-修改消息聊天框背景色-触发聊天让程序异常终止bug牵涉更多聊天消息发送优化处理-优雅草卓伊凡
102 10
【08】AI辅助编程完整的安卓二次商业实战-修改消息聊天框背景色-触发聊天让程序异常终止bug牵涉更多聊天消息发送优化处理-优雅草卓伊凡
|
20天前
|
存储 消息中间件 人工智能
【05】AI辅助编程完整的安卓二次商业实战-消息页面媒体对象(Media Object)布局实战调整-按钮样式调整实践-优雅草伊凡
【05】AI辅助编程完整的安卓二次商业实战-消息页面媒体对象(Media Object)布局实战调整-按钮样式调整实践-优雅草伊凡
65 11
【05】AI辅助编程完整的安卓二次商业实战-消息页面媒体对象(Media Object)布局实战调整-按钮样式调整实践-优雅草伊凡
|
20天前
|
XML 存储 Java
【06】AI辅助编程完整的安卓二次商业实战-背景布局变更增加背景-二开发现页面跳转逻辑-替换剩余图标-优雅草卓伊凡
【06】AI辅助编程完整的安卓二次商业实战-背景布局变更增加背景-二开发现页面跳转逻辑-替换剩余图标-优雅草卓伊凡
55 3
【06】AI辅助编程完整的安卓二次商业实战-背景布局变更增加背景-二开发现页面跳转逻辑-替换剩余图标-优雅草卓伊凡
|
20天前
|
存储 消息中间件 人工智能
【04】AI辅助编程完整的安卓二次商业实战-寻找修改替换新UI首页图标-菜单图标-消息列表图标-优雅草伊凡
【04】AI辅助编程完整的安卓二次商业实战-寻找修改替换新UI首页图标-菜单图标-消息列表图标-优雅草伊凡
52 4
|
27天前
|
Java 开发工具 Maven
【01】完整的安卓二次商业实战-详细的初级步骤同步项目和gradle配置以及开发思路-优雅草伊凡
【01】完整的安卓二次商业实战-详细的初级步骤同步项目和gradle配置以及开发思路-优雅草伊凡
99 6
|
3月前
|
安全 数据库 Android开发
在Android开发中实现两个Intent跳转及数据交换的方法
总结上述内容,在Android开发中,Intent不仅是活动跳转的桥梁,也是两个活动之间进行数据交换的媒介。运用Intent传递数据时需注意数据类型、传输大小限制以及安全性问题的处理,以确保应用的健壯性和安全性。
190 11
|
3月前
|
移动开发 Java 编译器
Kotlin与Jetpack Compose:Android开发生态的演进与架构思考
本文从资深Android工程师视角深入分析Kotlin与Jetpack Compose在Android系统中的技术定位。Kotlin通过空安全、协程等特性解决了Java在移动开发中的痛点,成为Android官方首选语言。Jetpack Compose则引入声明式UI范式,通过重组机制实现高效UI更新。两者结合不仅提升开发效率,更为跨平台战略和现代架构模式提供技术基础,代表了Android开发生态的根本性演进。
116 0
|
7月前
|
JavaScript Linux 网络安全
Termux安卓终端美化与开发实战:从下载到插件优化,小白也能玩转Linux
Termux是一款安卓平台上的开源终端模拟器,支持apt包管理、SSH连接及Python/Node.js/C++开发环境搭建,被誉为“手机上的Linux系统”。其特点包括零ROOT权限、跨平台开发和强大扩展性。本文详细介绍其安装准备、基础与高级环境配置、必备插件推荐、常见问题解决方法以及延伸学习资源,帮助用户充分利用Termux进行开发与学习。适用于Android 7+设备,原创内容转载请注明来源。
1416 77

热门文章

最新文章