RXJava的简单使用

1.导入依赖

    implementation 'io.reactivex:rxjava:1.0.14'implementation 'io.reactivex:rxandroid:1.0.1'

2.上代码：我们自己定义了三个方法。

//第一种方法是  Observerprivate void a() {//1.创建一个观察者Observer<String> observer = new Observer<String>(){//方法的执行顺序，如果订阅成功，则执行完onNext()，再执行onCompleted()，订阅失败则执行onError()@SuppressLint("LongLogTag")@Overridepublic void onCompleted() {Log.i(TAG, "Completed1");}@SuppressLint("LongLogTag")@Overridepublic void onError(Throwable e) {Log.i(TAG, "Error");}@SuppressLint("LongLogTag")@Overridepublic void onNext(String s) {Log.i(TAG, s);}};//2.使用Observable.create()创建被观察者Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {@Overridepublic void call(Subscriber<? super String> subscriber) {subscriber.onNext("Hello1");subscriber.onNext("Wrold1");subscriber.onCompleted();}});//3.订阅observable.subscribe(observer);}

//第二种方法是 Subscriberprivate void b(){//1.创建一个观察者Subscriber<String> subscriber = new Subscriber<String>(){@SuppressLint("LongLogTag")@Overridepublic void onCompleted() {Log.i(TAG, "Completed2");}@SuppressLint("LongLogTag")@Overridepublic void onError(Throwable e) {Log.i(TAG, "Error");}@SuppressLint("LongLogTag")@Overridepublic void onNext(String s) {Log.i(TAG, s);}};//2.使用Observable.create()创建被观察者Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {@Overridepublic void call(Subscriber<? super String> subscriber) {subscriber.onNext("Hello2");subscriber.onNext("Wrold2");subscriber.onCompleted();}});//3.订阅observable.subscribe(subscriber);}

 //第三种方法是 Subscriberprivate void c(){//1.创建一个观察者Subscriber<String> subscriber = new Subscriber<String>(){@SuppressLint("LongLogTag")@Overridepublic void onCompleted() {Log.i(TAG, "Completed3");}@SuppressLint("LongLogTag")@Overridepublic void onError(Throwable e) {Log.i(TAG, "Error");}@SuppressLint("LongLogTag")@Overridepublic void onNext(String s) {Log.i(TAG, "onNext: *******************/");Log.i(TAG, s);}};//2.使用Observable.just()创建被观察者Observable observable2 = Observable.just("Hello3", "World3","asdasd",1);//        subscribeOn() 就是对被观察者的线程的一个选择，一般都是后台的网络，数据流之类的。
//        observeOn() 就是观察者接受事件的一个线程选择，一般都是前台的UI,View更新之类的。observable2.subscribeOn(new Scheduler() {@Overridepublic Worker createWorker() {return null;}});observable2.observeOn(new Scheduler() {@Overridepublic Worker createWorker() {return null;}});//3.订阅observable2.subscribe(new Observable.OnSubscribe() {@SuppressLint("LongLogTag")@Overridepublic void call(Object o) {Log.i(TAG, "call:订阅成功**** "+o);}});/*Observable.just("Hello", ", RxJava!!").subscribe(new Action1<String>() {@Overridepublic void call(String s) {Log.e("LHC", "Action1:"+ s);}});*/}

RXJava的简单使用相关推荐

关于Rxjava的简单使用
本篇只是讲一下Rxjava的简单入门使用,想要详解的请移步其他博主文章,关于RxJava详解的文章网上一大堆,本片文章内容适合小白学习. 首先理解什么是RxJava,官方概念是RxJava 是一个在 ...
RxJava的简单学习（学习自扔物线）
首先说明下面这个是看扔物线大大的学习笔记,请直接前往这里看极其详细的入门版这里先给出这个歌开源库的github地址前言当前RxJava可是越来越火,也越来越多的人开始学习RxJava,越来越多的 ...
使用Spring Boot和RxJava的构建响应式REST API
点击蓝色"程序猿DD"关注我回复"资源"获取独家整理的学习资料! 我不打算解释什么是响应式编程,也不解释为什么要使用它.我希望你已经在其他地方了解过,如果没有 ...
继续谈谈从Rxjava迁移到Flow的背压策略
前言对于背压问题不久前就讨论过了,这里就不过多介绍了,总之它是一个非常复杂的话题,本文的主要目的是分析我们如何从Rxjava迁移到Flow并且使用其背压方案,由于本身技术的限制以及协程内部的复杂性, ...
Retrofit框架简单学习使用（举例：酷狗搜索和歌曲详情接口）
2019.09.24 说明:获取歌曲详情接口已失效,大家可根据自己实际url来测试. 首先先看效果图: 然后上Retrofit的注解表:(图片转自简书:https://www.jianshu.com/ ...
RxJava VS kotlin flow
1.基础概念介绍 1.1 观察者模式观察者模式,其实对于Android开发者而言,并不陌生,button的setOnClickListener,就是一个典型的观察者模式.控件button是被观察者, ...
Rxjava 学习总结
https://www.jianshu.com/p/52cd2d514528 RxJava的使用(三)转换--map.flatMap https://blog.csdn.net/wenyingzhi/ ...
RxJava2.0的生动形象的分析
响应式编程最近几年忽然间火起来了,尤其是RxJava出来以后,我也前前后后看了好多资料学习,最终总结出自己可以方便理解的文字,不想网上好多帖子写的那么高大上得文字.其实RxJava很简单,说白了他就是 ...
Retrofit响应数据及异常处理策略
今天我们来谈谈客户端对通讯协议的处理,主要分为三部分:约定响应数据格式,响应数据的自动映射以及错误处理三部分.由于数据协议采用json的居多,因此我们在此基础上进行说明. 约定响应数据格式协议格式 ...

RXJava的简单使用

RXJava的简单使用相关推荐

最新文章

热门文章