登录注册

当前位置：首页 > 文章列表 > 文章 > java教程 > RxJava2.x中，如何优雅地在Observable的onComplete回调后取消订阅？

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

2024-12-20 20:45:49 0浏览 收藏

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是文章学习者，那么本文《RxJava2.x中，如何优雅地在Observable的onComplete回调后取消订阅？》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

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

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

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

示例：

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

...
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());
    }
...
今天带大家了解了的相关知识，希望对你有所帮助；关于文章的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~
                
                

                                    

                                

                                        

                        
                            重庆无人机运输血液首航，九龙坡至沙坪坝 21 公里直线距离 18 分钟精确送达重庆无人机运输血液首航，九龙坡至沙坪坝 21 公里直线距离 18 分钟精确送达                        
                        

                            
上一篇

                            
重庆无人机运输血液首航，九龙坡至沙坪坝 21 公里直线距离 18 分钟精确送达

                        

                    

                                        

                        
                            如何为合并行后的 el-table 实现悬停样式？
                        
                        

                            
下一篇

                            
如何为合并行后的 el-table 实现悬停样式？

                        

                    

                                    

            
        
                

            

                

                    查看更多
                    
最新文章

                

            

            
        

    
    

        
        

            

                查看更多
                
课程推荐

            

            
    
                                
  • 
                    
                        前端进阶之JavaScript设计模式
                                            
                    
    
                        
    前端进阶之JavaScript设计模式
    
                        
    
                            设计模式是开发人员在软件开发过程中面临一般问题时的解决方案，代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景，打造一站式知识长龙服务，适合有JS基础的同学学习。                        
    
                        
    542次学习
    
                    
    
                
    • 
                                
  • 
                    
                        GO语言核心编程课程
                                            
                    
    
                        
    GO语言核心编程课程
    
                        
    
                            本课程采用真实案例，全面具体可落地，从理论到实践，一步一步将GO核心编程技术、编程思想、底层实现融会贯通，使学习者贴近时代脉搏，做IT互联网时代的弄潮儿。                        
    
                        
    508次学习
    
                    
    
                
    • 
                                
  • 
                    
                        简单聊聊mysql8与网络通信
                                            
                    
    
                        
    简单聊聊mysql8与网络通信
    
                        
    
                            如有问题加微信：Le-studyg；在课程中，我们将首先介绍MySQL8的新特性，包括性能优化、安全增强、新数据类型等，帮助学生快速熟悉MySQL8的最新功能。接着，我们将深入解析MySQL的网络通信机制，包括协议、连接管理、数据传输等，让                        
    
                        
    497次学习
    
                    
    
                
    • 
                                
  • 
                    
                        JavaScript正则表达式基础与实战
                                            
                    
    
                        
    JavaScript正则表达式基础与实战
    
                        
    
                            在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。                        
    
                        
    487次学习
    
                    
    
                
    • 
                                
  • 
                    
                        从零制作响应式网站—Grid布局
                                            
                    
    
                        
    从零制作响应式网站—Grid布局
    
                        
    
                            本系列教程将展示从零制作一个假想的网络科技公司官网，分为导航，轮播，关于我们，成功案例，服务流程，团队介绍，数据部分，公司动态，底部信息等内容区块。网站整体采用CSSGrid布局，支持响应式，有流畅过渡和展现动画。                        
    
                        
    484次学习
    
                    
    
                
    • 
                            

        

        

        

            查看更多
            
AI推荐

        

        
    
                        
  • 
                
                    笔灵AI生成答辩PPT：高效制作学术与职场PPT的利器
                
                
    
                    
    笔灵AI生成答辩PPT
    
                    
    
                        探索笔灵AI生成答辩PPT的强大功能，快速制作高质量答辩PPT。精准内容提取、多样模板匹配、数据可视化、配套自述稿生成，让您的学术和职场展示更加专业与高效。                    
    
                    
    28次使用
    
                
    
            
    • 
                        
  • 
                
                    知网AIGC检测服务系统：精准识别学术文本中的AI生成内容
                
                
    
                    
    知网AIGC检测服务系统
    
                    
    
                        知网AIGC检测服务系统，专注于检测学术文本中的疑似AI生成内容。依托知网海量高质量文献资源，结合先进的“知识增强AIGC检测技术”，系统能够从语言模式和语义逻辑两方面精准识别AI生成内容，适用于学术研究、教育和企业领域，确保文本的真实性和原创性。                    
    
                    
    42次使用
    
                
    
            
    • 
                        
  • 
                
                    AIGC检测服务：AIbiye助力确保论文原创性
                
                
    
                    
    AIGC检测-Aibiye
    
                    
    
                        AIbiye官网推出的AIGC检测服务，专注于检测ChatGPT、Gemini、Claude等AIGC工具生成的文本，帮助用户确保论文的原创性和学术规范。支持txt和doc(x)格式，检测范围为论文正文，提供高准确性和便捷的用户体验。                    
    
                    
    39次使用
    
                
    
            
    • 
                        
  • 
                
                    易笔AI论文平台：快速生成高质量学术论文的利器
                
                
    
                    
    易笔AI论文
    
                    
    
                        易笔AI论文平台提供自动写作、格式校对、查重检测等功能，支持多种学术领域的论文生成。价格优惠，界面友好，操作简便，适用于学术研究者、学生及论文辅导机构。                    
    
                    
    51次使用
    
                
    
            
    • 
                        
  • 
                
                    笔启AI论文写作平台：多类型论文生成与多语言支持
                
                
    
                    
    笔启AI论文写作平台
    
                    
    
                        笔启AI论文写作平台提供多类型论文生成服务，支持多语言写作，满足学术研究者、学生和职场人士的需求。平台采用AI 4.0版本，确保论文质量和原创性，并提供查重保障和隐私保护。                    
    
                    
    42次使用
    
                
    
            
    • 
                    

    

        
        

            

                查看更多
                
相关文章

            

            
        

    




    

        

            

                关于我们
                免责声明
                意见反馈
                联系我们
                内容提交
            

            
Golang学习网：公益在线Go学习平台，帮助Go学习者快速成长！

            

                技术交流群
            

            

                Copyright 2023 http://www.17golang.com/ All Rights Reserved ｜ 苏ICP备2023003363号-1
            

        

        

            
    
                
                
  • 
                    
    
                        Golang学习网
                    
    
                    
    关注公众号
    
                    
    Golang学习网
    
                
    • 
                
    
            

        

        

    







    

      

        
      

      
      
      
      

        

        

          
微信登录更方便

        

        

          
    
            
  • 密码登录
    •  
            
  • 注册账号
    • 
          

          

            

              

                
                                

                  
                

                

                  
                

                

                  

                    
                  

                
                    
                
              

                

                  忘记密码
                

                

                  
                

              
            

            
          

        

        
登录即同意 用户协议 和 隐私政策

      

		
		

			

			
返回登录

			

			
    
				
  • 重置密码
    • 
			

			

				

				

          

          
        

					
          

            

              
            

            
                发送验证码