讲师中心 微信公众号
首页
文章
后端开发 web前端 数据库 开发工具 php框架 常见问题 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 自媒体 新闻
专题
后端开发 web前端 数据库 开发工具 php框架 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 新闻
AI工具
AI 聊天问答 Agent智能体 AI 文本写作 AI 绘画作图 AI 设计工具 AI 视频创作 AI 音频制作 AI 办公学习 AI 编程开发 Prompt指令
学习
大前端 后端开发 数据库 移动端 运维开发 计算机基础
编程手册
大前端 后端开发 数据库 移动端 运维开发 计算机基础
下载
js特效 网站源码 工具下载 类库下载 网站素材 学习资源 插件扩展 手机游戏
最近更新
当前位置：首页 > Java > java教程 >

正文

0

0

RxJava 基础用法案例分享源码解析【附代码】

php是最好的语言

php是最好的语言

发布时间：2018-07-24 15:02:23

|

1611人浏览过

|

来源于php中文网

原创

本文详述RxJava的基础用法， RxJava是一个用法很简单的神奇框架,但内部实现有点复杂,代码逻辑有点绕。网上关于RxJava源码分析的文章,源码贴很少且不全，下面罗列了完整的源码解析，供参考。

1.rxjava 基础用法

  Observable.create(new Observable.OnSubscribe() {
            @Override
            public void call(Subscriber subscriber) {
                
            }
        }).subscribe(new Observer() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(Object o) {

            }
        });
2.先看 .subscribe(new Observer() )这个方法
 public final Subscription subscribe(final Observer observer) {
        if (observer instanceof Subscriber) {
            return subscribe((Subscriber)observer);
        }
        if (observer == null) {
            throw new NullPointerException("observer is null");
        }
        return subscribe(new ObserverSubscriber(observer));
    }
这里只是将传进来的observer 参数进行了简单的封装（ObserverableSubscriber）


继续看subscribe 方法
 public final Subscription subscribe(Subscriber subscriber) {
        return Observable.subscribe(subscriber, this);
    }
 static  Subscription subscribe(Subscriber subscriber, Observable observable) {
     // validate and proceed
        if (subscriber == null) {
            throw new IllegalArgumentException("subscriber can not be null");
        }
        if (observable.onSubscribe == null) {
            throw new IllegalStateException("onSubscribe function can not be null.");
            /*
             * the subscribe function can also be overridden but generally that's not the appropriate approach
             * so I won't mention that in the exception
             */
        }

        // new Subscriber so onStart it
        subscriber.onStart();

        /*
         * See https://github.com/ReactiveX/RxJava/issues/216 for discussion on "Guideline 6.4: Protect calls
         * to user code from within an Observer"
         */
        // if not already wrapped
        if (!(subscriber instanceof SafeSubscriber)) {
            // assign to `observer` so we return the protected version
            subscriber = new SafeSubscriber(subscriber);
        }

        // The code below is exactly the same an unsafeSubscribe but not used because it would
        // add a significant depth to already huge call stacks.
        try {
            // allow the hook to intercept and/or decorate
            RxJavaHooks.onObservableStart(observable, observable.onSubscribe).call(subscriber);
            return RxJavaHooks.onObservableReturn(subscriber);
        } catch (Throwable e) {
            // special handling for certain Throwable/Error/Exception types
            Exceptions.throwIfFatal(e);
            // in case the subscriber can't listen to exceptions anymore
            if (subscriber.isUnsubscribed()) {
                RxJavaHooks.onError(RxJavaHooks.onObservableError(e));
            } else {
                // if an unhandled error occurs executing the onSubscribe we will propagate it
                try {
                    subscriber.onError(RxJavaHooks.onObservableError(e));
                } catch (Throwable e2) {
                    Exceptions.throwIfFatal(e2);
                    // if this happens it means the onError itself failed (perhaps an invalid function implementation)
                    // so we are unable to propagate the error correctly and will just throw
                    RuntimeException r = new OnErrorFailedException("Error occurred attempting to subscribe [" + e.getMessage() + "] and then again while trying to pass to onError.", e2);
                    // TODO could the hook be the cause of the error in the on error handling.
                    RxJavaHooks.onObservableError(r);
                    // TODO why aren't we throwing the hook's return value.
                    throw r; // NOPMD
                }
            }
            return Subscriptions.unsubscribed();
        }
    }
这里面只需要注意


立即学习“Java免费学习笔记（深入）”；
  RxJavaHooks.onObservableStart(observable, observable.onSubscribe).call(subscriber);
    public static  Observable.OnSubscribe onObservableStart(Observable instance, Observable.OnSubscribe onSubscribe) {
        Func2 f = onObservableStart;
        if (f != null) {
            return f.call(instance, onSubscribe);
        }
        return onSubscribe;
    }
RxJavaHooks.onObservableStart(observable, observable.onSubscribe) 
这个方法返回的是它的第二个参数，也就是Observable它自己的onSubscribe 对象，
所以在subscribe 方法里面调用了  onSubscribe.call(subscriber)方法
这里的subscriber 就是传进来的参数

							

								医真AI+开放平台
								

									医真AI+开放平台
									
医真AI+ 医学AI开放平台

								

								下载 
							

						
protected Observable(OnSubscribe f) {
        this.onSubscribe = f;
    }
public static  Observable create(OnSubscribe f) {
        return new Observable(RxJavaHooks.onCreate(f));
    }
可以看出onSubscribe 对象 是create 传进来的参数，那么整个流程就很清楚了


只有调用了subscribe 方法整个流程才会执行 ：subscribe ===>调用 onSubscribe.call(observer) 方法 同时也把observer 传递进去了


相关推荐：


RxJava操作符（八）Aggregate_PHP教程


视频：JavaScript 基础加强视频教程
					
					

													

								
相关文章

							

							

																	
										
Java初学者项目实战：开发简单的命令行应用

									
																	
										
Java如何实现网络音频流播放 Java播放网络电台URL音频流【教程】

									
																	
										
Java常用输入输出类库与BufferedReader

									
																	
										
java的音频处理方法有哪些 java的音频处理方法是什么

									
																	
										
学Java哪个网站好_主流Java学习网站综合对比评测

									
															

													

							

								java速学教程(入门到精通)
								

									java速学教程(入门到精通)
									
java怎么学习？java怎么入门？java在哪学？java怎么学才快？不用担心，这里为大家提供了java速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！

								

								下载 
							

						
							

								
相关标签:

								

									JavaScript Object 封装 对象 rxjava								

							

						
						
本站声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

						

													上一篇：怎样学习Java--javascript零基础经典权威指南
													下一篇：Java中常用的一种代理设计模式—示例总结
												

					


					

													

								

									
 
										
作者最新文章

									

								

																	

										

											
												
各大公司Java面试题归纳整理（全）

											
											

												
2018-08-10 15:43

											

										

								

																	

										

											
												
实战演练--js实现在网页间传递数据

											
											

												
2018-08-10 16:16

											

										

								

																	

										

											
												
js 闭包与原型的应用代码详解

											
											

												
2018-08-10 16:35

											

										

								

																	

										

											
												
什么是模块化编程？js 模块化编程的总结

											
											

												
2018-08-10 16:51

											

										

								

																	

										

											
												
js可视区域加载：getBoundingClientRect方法

											
											

												
2018-08-10 16:56

											

										

								

																	

										

											
												
Paypal 支付功能的 C# .NET / JS 实现

											
											

												
2018-08-10 17:11

											

										

								

																	

										

											
												
最新整理的JavaScript常见事件类型

											
											

												
2018-08-10 17:21

											

										

								

																	

										

											
												
js的三大舍入函数（round()， ceil() ，floor()）的对比

											
											

												
2018-08-10 17:44

											

										

								

																	

										

											
												
详解js中call()、apply()、bind()的用法

											
											

												
2018-08-10 17:50

											

										

								

																	

										

											
												
微信开发教程：自动回复消息和客服消息，文本带链接跳转

											
											

												
2018-08-10 17:53

											

										

								

															

						
						

							

								
 
									
热门AI工具

								

								更多
							


							

																	

										
											DeepSeek
											

												
DeepSeek

												
幻方量化公司旗下的开源大模型平台

																									

																												
AI大模型

																													
开放平台

																											

																							

										
									

																	

										
											豆包大模型
											

												
豆包大模型

												
字节跳动自主研发的一系列大型语言模型

																									

																												
AI大模型

																											

																							

										
									

																	

										
											通义千问
											

												
通义千问

												
阿里巴巴推出的全能AI助手

																									

																												
AI大模型

																											

																							

										
									

																	

										
											腾讯元宝
											

												
腾讯元宝

												
腾讯混元平台推出的AI助手

																									

																												
文档处理

																													
Excel 表格

																											

																							

										
									

																	

										
											文心一言
											

												
文心一言

												
文心一言是百度开发的AI聊天机器人，通过对话可以生成各种形式的内容。

																									

																												
AI大模型

																													
中文写作

																											

																							

										
									

																	

										
											讯飞写作
											

												
讯飞写作

												
基于讯飞星火大模型的AI写作工具，可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

																									

																												
中文写作

																													
写作工具

																											

																							

										
									

																	

										
											即梦AI
											

												
即梦AI

												
一站式AI创作平台，免费AI图片和视频生成。

																									

																												
图片拼接

																													
图画生成

																											

																							

										
									

																	

										
											ChatGPT
											

												
ChatGPT

												
最最强大的AI聊天机器人程序，ChatGPT不单是聊天机器人，还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

																									

																												
AI大模型

																													
中文写作

																											

																							

										
									

																	

										
											智谱清言 - 免费全能的AI助手
											

												
智谱清言 - 免费全能的AI助手

												
智谱清言 - 免费全能的AI助手

																									

																												
AI大模型

																													
PDF 文档

																											

																							

										
									

															





						


					



				


			
			

				

                    
                

				

					

						
 
							
相关专题

						

						更多
					

					

													

								js获取数组长度的方法
								

									js获取数组长度的方法
									
在js中，可以利用array对象的length属性来获取数组长度，该属性可设置或返回数组中元素的数目，只需要使用“array.length”语句即可返回表示数组对象的元素个数的数值，也就是长度值。php中文网还提供JavaScript数组的相关下载、相关课程等内容，供大家免费下载使用。

									

										
 
											
554

										

										
 
											
2023.06.20

										

									

								

							

													

								js刷新当前页面
								

									js刷新当前页面
									
js刷新当前页面的方法：1、reload方法，该方法强迫浏览器刷新当前页面，语法为“location.reload([bForceGet]) ”；2、replace方法，该方法通过指定URL替换当前缓存在历史里（客户端）的项目，因此当使用replace方法之后，不能通过“前进”和“后退”来访问已经被替换的URL，语法为“location.replace(URL) ”。php中文网为大家带来了js刷新当前页面的相关知识、以及相关文章等内容

									

										
 
											
374

										

										
 
											
2023.07.04

										

									

								

							

													

								js四舍五入
								

									js四舍五入
									
js四舍五入的方法：1、tofixed方法，可把 Number 四舍五入为指定小数位数的数字；2、round() 方法，可把一个数字舍入为最接近的整数。php中文网为大家带来了js四舍五入的相关知识、以及相关文章等内容

									

										
 
											
732

										

										
 
											
2023.07.04

										

									

								

							

													

								js删除节点的方法
								

									js删除节点的方法
									
js删除节点的方法有：1、removeChild()方法，用于从父节点中移除指定的子节点，它需要两个参数，第一个参数是要删除的子节点，第二个参数是父节点；2、parentNode.removeChild()方法，可以直接通过父节点调用来删除子节点；3、remove()方法，可以直接删除节点，而无需指定父节点；4、innerHTML属性，用于删除节点的内容。

									

										
 
											
477

										

										
 
											
2023.09.01

										

									

								

							

													

								JavaScript转义字符
								

									JavaScript转义字符
									
JavaScript中的转义字符是反斜杠和引号，可以在字符串中表示特殊字符或改变字符的含义。本专题为大家提供转义字符相关的文章、下载、课程内容，供大家免费下载体验。

									

										
 
											
394

										

										
 
											
2023.09.04

										

									

								

							

													

								js生成随机数的方法
								

									js生成随机数的方法
									
js生成随机数的方法有：1、使用random函数生成0-1之间的随机数；2、使用random函数和特定范围来生成随机整数；3、使用random函数和round函数生成0-99之间的随机整数；4、使用random函数和其他函数生成更复杂的随机数；5、使用random函数和其他函数生成范围内的随机小数；6、使用random函数和其他函数生成范围内的随机整数或小数。

									

										
 
											
991

										

										
 
											
2023.09.04

										

									

								

							

													

								如何启用JavaScript
								

									如何启用JavaScript
									
JavaScript启用方法有内联脚本、内部脚本、外部脚本和异步加载。详细介绍：1、内联脚本是将JavaScript代码直接嵌入到HTML标签中；2、内部脚本是将JavaScript代码放置在HTML文件的`<script>`标签中；3、外部脚本是将JavaScript代码放置在一个独立的文件；4、外部脚本是将JavaScript代码放置在一个独立的文件。

									

										
 
											
657

										

										
 
											
2023.09.12

										

									

								

							

													

								Js中Symbol类详解
								

									Js中Symbol类详解
									
javascript中的Symbol数据类型是一种基本数据类型，用于表示独一无二的值。Symbol的特点：1、独一无二，每个Symbol值都是唯一的，不会与其他任何值相等；2、不可变性，Symbol值一旦创建，就不能修改或者重新赋值；3、隐藏性，Symbol值不会被隐式转换为其他类型；4、无法枚举，Symbol值作为对象的属性名时，默认是不可枚举的。

									

										
 
											
551

										

										
 
											
2023.09.20

										

									

								

							

													

								高德地图升级方法汇总
								

									高德地图升级方法汇总
									
本专题整合了高德地图升级相关教程，阅读专题下面的文章了解更多详细内容。

									

										
 
											
27

										

										
 
											
2026.01.16

										

									

								

							

											

				


				

					

						
 
							
热门下载

						

						更多
					

					

						

							
网站特效  
 /
							
网站源码 
 /
							
网站素材 
 /
							
前端模板 

						

						
						
						
						
					

					

				


				

					
                




				

					

						
 
							
相关下载

						

						更多
					

					

											
php商城系统

											
淘源码商城PHP淘宝查信誉

											
PHP房产程序[BBWPS]

											
PHP简约自动发卡平台个人版

											
ERMEB域名PHP离线网络授权系统

											
Difeye-敏捷的轻量级PHP框架

											
大泉州汽车网PHP整站程序

										


				


				

					

						
 
							
精品课程

						

						更多
					

					

						

							
相关推荐  
 /
							
热门推荐 
 /
							
最新课程 

						

						

													

								
									php-src源码分析探索
								
								

									php-src源码分析探索

									

										
共6课时 | 0.5万人学习

									

								

							

													

								
									PHP自制框架
								
								

									PHP自制框架

									

										
共8课时 | 0.6万人学习

									

								

							

													

								
									c语言项目php解释器源码分析探索
								
								

									c语言项目php解释器源码分析探索

									

										
共7课时 | 0.4万人学习

									

								

							

												


						

						
						

					

				


				

					

						
 
							
最新文章

						

						更多
					

					

													
标题：RecyclerView 删除功能失效的根源与正确实现方案

													
JVM内存模型和内存结构_JVM内存模型组成与各结构功能

													
在Java中如何编写模拟登录验证码_Java随机数项目解析

													
在Java中如何安装并配置Spring Boot环境_Java框架环境搭建解析

													
OOP对象之间的关系有哪些_Java面向对象编程关联方式说明

													
在Java里如何设计对象之间的协作模式_协作模式对系统复杂性的优化

													
Java多态学习笔记：从入门到精通

													
在Java中instanceof关键字作用是什么_Java类型检查说明

													
如何找到避开所有障碍物的最小固定跳跃长度

													
在Java里ArrayList适合什么使用场景_Java动态数组原理说明

											


				







			




		

	
	
	

    

        

            

                

                    

                        关于我们
                        免责申明
                        举报中心
                        意见反馈
                        讲师合作
                        广告合作
                        最新更新
                                                

                    

                    
php中文网：公益在线php培训，帮助PHP学习者快速成长！

                    

                      
                        关注服务号
                        
                      
                        
                        技术交流群
                        
                      
                        

                    

                

                
            

            

                

                    
                    

                        
PHP中文网订阅号

                        
每天精选资源文章推送

                    

                

            

        

    

    

        
Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

    













	
	
		
	
	


    
  • 
        
    
            
    
                
                    
                    
    PHP学习
    
                    
            
    
        
    
    
    • 
    
  • 
        
    
            
    
                
                    
                    
    技术支持
    
                    
            
    
        
    
    
    • 
    
  • 
        
    
            
    
                
                    
                    
    返回顶部
    
                    
            
    
        
    
    
    •