登录注册

当前位置：首页 > 文章列表 > 文章 > java教程 > RxJava中如何优雅地在onComplete调用时取消订阅？

RxJava中如何优雅地在onComplete调用时取消订阅？

2024-12-13 20:28:03 0浏览 收藏

怎么入门文章编程？需要学习哪些知识点？这是新手们刚接触编程时常见的问题；下面golang学习网就来给大家整理分享一些知识点，希望能够给初学者一些帮助。本篇文章就来介绍《RxJava中如何优雅地在onComplete调用时取消订阅？》，涉及到，有需要的可以收藏一下

RxJava中如何优雅地在onComplete调用时取消订阅？

如何在 rxjava 中在 oncomplete 调用时取消订阅

在 rxjava 中，通常希望在 observable 的 oncomplete 事件上取消订阅，以防止进一步的事件发射。这可以通过设置 completablefuture 来实现。

非 android 环境中使用 rxjava 2.x 的示例

flowable 由持久层方法返回，作为调用方中的 result.getall(dbname.get(), strategy) 和 result.gettablecolumn(table)。

public class consoleschemaflowableoutput implements schemaflowableoutput {
    private static final logger logger = loggerfactory.getlogger(consoleschemaflowableoutput.class);
    private volatile completablefuture future = new completablefuture<>();
    private atomicinteger count = new atomicinteger(0);

    @override
    public disposable flush(information information, flowable table) throws schemaexportexception {
        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;
    }

    @override
    public completablefuture getfuture() {
        return future;
    }
    ...
}
调用方
public void export(Information info, SchemaFlowableOutput out) throws SchemaExportException {
    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());
    }
}

private void clearHander(Disposable disposable, String reason) {
    logger.info(reason);
    if (null != disposable && !disposable.isDisposed()) {
        disposable.dispose();
    } else {
        if (null != disposable) {
            logger.info("[CH]disposable status:" + disposable.isDisposed());
        } else {
            logger.info("[CH]disposable is null:");
        }
    }
    // 结束后的回调,执行一些清理工作
    completeHandler.apply();
}
通过将 completablefuture 设置为 "ok" 来通知调用方 observable 已结束，这将取消订阅并执行后续处理。
到这里，我们也就讲完了《RxJava中如何优雅地在onComplete调用时取消订阅？》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！
                
                

                                    

                                

                                        

                        
                            Java List.toArray方法：为什么数组中会填充null值？Java List.toArray方法：为什么数组中会填充null值？                        
                        

                            
上一篇

                            
Java List.toArray方法：为什么数组中会填充null值？

                        

                    

                                        

                        
                            轻松上手：电脑制作PPT的完整指南
                        
                        

                            
下一篇

                            
轻松上手：电脑制作PPT的完整指南

                        

                    

                                    

            
        
                

            

                

                    查看更多
                    
最新文章

                

            

            
        

    
    

        
        

            

                查看更多
                
课程推荐

            

            
    
                                
  • 
                    
                        前端进阶之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 Make Song：零门槛AI音乐创作平台，助你轻松制作个性化音乐
                
                
    
                    
    AI Make Song
    
                    
    
                        AI Make Song是一款革命性的AI音乐生成平台，提供文本和歌词转音乐的双模式输入，支持多语言及商业友好版权体系。无论你是音乐爱好者、内容创作者还是广告从业者，都能在这里实现“用文字创造音乐”的梦想。平台已生成超百万首原创音乐，覆盖全球20个国家，用户满意度高达95%。                    
    
                    
    4次使用
    
                
    
            
    • 
                        
  • 
                
                    SongGenerator.io：零门槛AI音乐生成器，快速创作高质量音乐
                
                
    
                    
    SongGenerator
    
                    
    
                        探索SongGenerator.io，零门槛、全免费的AI音乐生成器。无需注册，通过简单文本输入即可生成多风格音乐，适用于内容创作者、音乐爱好者和教育工作者。日均生成量超10万次，全球50国家用户信赖。                    
    
                    
    4次使用
    
                
    
            
    • 
                        
  • 
                
                     BeArt AI换脸：免费在线工具，轻松实现照片、视频、GIF换脸
                
                
    
                    
    BeArt AI换脸
    
                    
    
                         探索BeArt AI换脸工具，免费在线使用，无需下载软件，即可对照片、视频和GIF进行高质量换脸。体验快速、流畅、无水印的换脸效果，适用于娱乐创作、影视制作、广告营销等多种场景。                    
    
                    
    4次使用
    
                
    
            
    • 
                        
  • 
                
                    SEO标题协启动：AI驱动的智能对话与内容生成平台 - 提升创作效率
                
                
    
                    
    协启动
    
                    
    
                        SEO摘要协启动（XieQiDong Chatbot）是由深圳协启动传媒有限公司运营的AI智能服务平台，提供多模型支持的对话服务、文档处理和图像生成工具，旨在提升用户内容创作与信息处理效率。平台支持订阅制付费，适合个人及企业用户，满足日常聊天、文案生成、学习辅助等需求。                    
    
                    
    11次使用
    
                
    
            
    • 
                        
  • 
                
                    Brev AI：零注册门槛的全功能免费AI音乐创作平台
                
                
    
                    
    Brev AI
    
                    
    
                        探索Brev AI，一个无需注册即可免费使用的AI音乐创作平台，提供多功能工具如音乐生成、去人声、歌词创作等，适用于内容创作、商业配乐和个人创作，满足您的音乐需求。                    
    
                    
    12次使用
    
                
    
            
    • 
                    

    

        
        

            

                查看更多
                
相关文章

            

            
        

    




    

        

            

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

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

            

                技术交流群
            

            

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

        

        

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

        

        

    







    

      

        
      

      
      
      
      

        

        

          
微信登录更方便

        

        

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

          

            

              

                
                                

                  
                

                

                  
                

                

                  

                    
                  

                
                    
                
              

                

                  忘记密码
                

                

                  
                

              
            

            
          

        

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

      

		
		

			

			
返回登录

			

			
    
				
  • 重置密码
    • 
			

			

				

				

          

          
        

					
          

            

              
            

            
                发送验证码