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

正文

0

0

RxJava2.x中，如何优雅地在Observable的onComplete回调后取消订阅？

聖光之護

聖光之護

发布时间：2024-11-30 16:51:53

|

1010人浏览过

|

来源于php中文网

原创

rxjava2.x中，如何优雅地在observable的oncomplete回调后取消订阅？

rxjava的observable订阅时如何实现oncomplete取消订阅

使用rxjava 2.x时，要在oncomplete被调用时取消订阅，可以使用completablefuture.complete向调用方发送完成信号。

示例：

flowable由持久层方法返回，以下是调用方中的代码：

ArrowMancer
ArrowMancer

手机上的宇宙动作RPG，游戏角色和元素均为AI生成

下载

立即学习“Java免费学习笔记（深入）”；

...
private volatile completablefuture future = new completablefuture<>();
private atomicinteger count = new atomicinteger(0);
@override
public disposable flush(information information, flowable table) throws schemaexportexception {
    logger.info("start flowable flush");
    disposable export_flush_complete = table.subscribe(tableins -> {
        system.out.println(printasciitable(tableins));
        system.out.println(printasciicolumns(tableins.getcolumns()));
        system.out.println("\r\n");
        count.addandget(1);
    }, throwable -> {
        logger.debug("export break, reason: " + throwable.getmessage());
        future.cancel(true);
        throw new schemaexportexception(throwable);
    }, new action() {
        @override
        public void run() throws exception {
            logger.debug("export complete, affect size:" + count.get());
            future.complete("ok");
        }
    });
    return export_flush_complete;
}
...
调用方的代码：
...
    long startStamp = System.currentTimeMillis();
    // Flowable
    Flowable
 tableFlowable = result.getAll(dbName.get(), strategy).flatMap(new Function>() {
        @Override
        public Publisher
 apply(@NonNull Table table) throws Exception {
            return result.getTableColumn(table).flatMap(new Function, SingleSource
>() {
                @Override
                public SingleSource
 apply(@NonNull List columns) throws Exception {
                    return Single.just(table.fillColumn(columns));
                }
            }).flatMapPublisher(new Function>() {
                @Override
                public Publisher apply(@NonNull Table table) throws Exception {
                    return Flowable.just(table);
                }
            });
        }
    });
    Disposable disposable = null;
    try {
        disposable = out.flush(info, tableFlowable);
        CompletableFuture future = out.getFuture();
        while (!future.isDone()) {
            logger.info("[ERE-Flowable]未完成,线程休眠1秒");
            Thread.currentThread().sleep(1000, 0);
        }
        String result = future.get();
        logger.info("[ERE-Flowable]完成, 结果:" + result);
        if (result.equals("OK")) {
            long finishStamp = System.currentTimeMillis();
            clearHander(disposable, "[ERE-Flowable]RxJava disposed because complete, WithTime: " + (finishStamp - startStamp));
        }
    } catch (Exception e) {
        clearHander(disposable, "[ERE-Flowable]RxJava disposed has Exception: " + e.getMessage());
    }
...					
					

													

								
相关标签:

								

									rxjava								

							

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

						

													上一篇：RxJava2.x中如何优雅地在Observable的onComplete后取消订阅？
													下一篇：Java List.toArray方法：为什么传入数组比List长时结果并非预期？
												

					


					

													

								

									
 
										
作者最新文章

									

								

																	

										

											
												
如何在 Go 中读取包含多个单词的控制台输入字符串

											
											

												
2026-01-21 09:54

											

										

								

																	

										

											
												
如何让 Bootstrap 登录页完整填充全屏（解决内容截断问题）

											
											

												
2026-01-21 09:57

											

										

								

																	

										

											
												
如何使用解构赋值高效更新对象的多个属性

											
											

												
2026-01-21 09:57

											

										

								

																	

										

											
												
如何在 Selectize 下拉选项中添加国旗图标（SVG/IMG）

											
											

												
2026-01-21 10:00

											

										

								

																	

										

											
												
如何在 React 列表中仅对单个项触发状态变更？

											
											

												
2026-01-21 10:01

											

										

								

																	

										

											
												
如何在数据库中按优先级分批扣减库存（支持跨多条记录的原子化扣减）

											
											

												
2026-01-21 10:19

											

										

								

																	

										

											
												
如何在删除嵌套字典中不符合条件的项后重编号键值

											
											

												
2026-01-21 10:21

											

										

								

																	

										

											
												
《龙腾世纪4》失利 导致《质量效应5》开发进程受阻

											
											

												
2026-01-21 10:21

											

										

								

																	

										

											
												
Java 8 Streams 实现嵌套 Map 结构的条件筛选

											
											

												
2026-01-21 10:24

											

										

								

																	

										

											
												
如何通过 CSS 为内联 SVG 元素应用滤镜效果

											
											

												
2026-01-21 10:26

											

										

								

															

						
						

							

								
 
									
热门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 文档

																											

																							

										
									

															





						


					



				


			
			

				

                    
                

				

					

						
 
							
相关专题

						

						更多
					

					

													

								Java编译相关教程合集
								

									Java编译相关教程合集
									
本专题整合了Java编译相关教程，阅读专题下面的文章了解更多详细内容。

									

										
 
											
11

										

										
 
											
2026.01.21

										

									

								

							

													

								C++多线程相关合集
								

									C++多线程相关合集
									
本专题整合了C++多线程相关教程，阅读专题下面的的文章了解更多详细内容。

									

										
 
											
4

										

										
 
											
2026.01.21

										

									

								

							

													

								无人机驾驶证报考 uom民用无人机综合管理平台官网
								

									无人机驾驶证报考 uom民用无人机综合管理平台官网
									
无人机驾驶证（CAAC执照）报考需年满16周岁，初中以上学历，身体健康（矫正视力1.0以上，无严重疾病），且无犯罪记录。个人需通过民航局授权的训练机构报名，经理论（法规、原理）、模拟飞行、实操（GPS/姿态模式）及地面站训练后考试合格，通常15-25天拿证。

									

										
 
											
16

										

										
 
											
2026.01.21

										

									

								

							

													

								Python多线程合集
								

									Python多线程合集
									
本专题整合了Python多线程相关教程，阅读专题下面的文章了解更多详细内容。

									

										
 
											
1

										

										
 
											
2026.01.21

										

									

								

							

													

								java多线程相关教程合集
								

									java多线程相关教程合集
									
本专题整合了java多线程相关教程，阅读专题下面的文章了解更多详细内容。

									

										
 
											
4

										

										
 
											
2026.01.21

										

									

								

							

													

								windows激活码分享 windows一键激活教程指南
								

									windows激活码分享 windows一键激活教程指南
									
Windows 10/11一键激活可以通过PowerShell脚本或KMS工具实现永久或长期激活。最推荐的简便方法是打开PowerShell（管理员），运行 irm https://get.activated.win | iex 脚本，按提示选择数字激活（选项1）。其他方法包括使用HEU KMS Activator工具进行智能激活。

									

										
 
											
2

										

										
 
											
2026.01.21

										

									

								

							

													

								excel表格操作技巧大全 表格制作excel教程
								

									excel表格操作技巧大全 表格制作excel教程
									
Excel表格操作的核心技巧在于
熟练使用快捷键、数据处理函数及视图工具，如Ctrl+C/V（复制粘贴）、Alt+=（自动求和）、条件格式、数据验证及数据透视表。掌握这些可大幅提升数据分析与办公效率，实现快速录入、查找、筛选和汇总。

									

										
 
											
6

										

										
 
											
2026.01.21

										

									

								

							

													

								毒蘑菇显卡测试网站入口 毒蘑菇测试官网volumeshader_bm
								

									毒蘑菇显卡测试网站入口 毒蘑菇测试官网volumeshader_bm
									
毒蘑菇VOLUMESHADER_BM测试网站网址为https://toolwa.com/vsbm/，该平台基于WebGL技术通过渲染高复杂度三维分形图形评估设备图形处理能力，用户可通过拖动彩色物体观察画面流畅度判断GPU与CPU协同性能；测试兼容多种设备，但中低端手机易卡顿或崩溃，高端机型可能因发热降频影响表现，桌面端需启用独立显卡并使用支持WebGL的主流浏览器以确保准确结果

									

										
 
											
25

										

										
 
											
2026.01.21

										

									

								

							

													

								github中文官网入口 github中文版官网网页进入
								

									github中文官网入口 github中文版官网网页进入
									
github中文官网入口https://docs.github.com/zh/get-started，GitHub 是一种基于云的平台，可在其中存储、共享并与他人一起编写代码。 通过将代码存储在GitHub 上的“存储库”中，你可以： “展示或共享”你的工作。 持续“跟踪和管理”对代码的更改。

									

										
 
											
7

										

										
 
											
2026.01.21

										

									

								

							

											

				


				

					

						
 
							
热门下载

						

						更多
					

					

						

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

						

						
						
						
						
					

					

				


				

					
                




				

					

						
 
							
相关下载

						

						更多
					

					

											
php商城系统

											
淘源码商城PHP淘宝查信誉

											
PHP房产程序[BBWPS]

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

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

											
Difeye-敏捷的轻量级PHP框架

											
大泉州汽车网PHP整站程序

										


				


				

					

						
 
							
精品课程

						

						更多
					

					

						

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

						

						

												


						

						
						

					

				


				

					

						
 
							
最新文章

						

						更多
					

					

													
在Java里接口的核心作用是什么_Java接口设计思想解析

													
在Java中如何开发学生成绩管理程序_Java基础项目结构说明

													
如何使用 Java 高效合并多个 MP4 文件（推荐 FFmpeg 方案）

													
如何使用 Java 高效合并多个 MP4 文件（避免逐次合并导致的编码损坏）

													
如何在 Java 中正确初始化并访问嵌套列表（二维 List）

													
如何在 Spring Boot 中通过 HTTP 请求头获取并回传用户 ID

													
如何避免文件在上传 AWS S3 时意外保存到本地项目目录

													
如何在 Java 中正确导入并使用外部类的二维列表

													
如何避免文件同时保存到本地项目目录和 AWS S3（Java 实现）

													
如何在Java中正确初始化并访问嵌套列表（二维List）

											


				







			




		

	
	
	

    

        

            

                

                    

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

                    

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

                    

                      
                        关注服务号
                        
                      
                        
                        技术交流群
                        
                      
                        

                    

                

                
            

            

                

                    
                    

                        
PHP中文网订阅号

                        
每天精选资源文章推送

                    

                

            

        

    

    

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

    













	
	
		
	
	


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