1. 首页
  2. 编程教程
  3. java教程

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

6 阅读 0 评论

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

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

示例：

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

立即学习“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("
");
        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<? extends Table> 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());
    }
... 登录后复制 

以上就是RxJava2.x中，如何优雅地在Observable的onComplete回调后取消订阅？的详细内容，更多请关注慧达安全导航其它相关文章！
                        

                        
                    

                    


免责 声明


1、本网站名称：慧达安全导航

2、本站永久网址：https//www.huida178.com/

3、本站所有资源来源于网友投稿和高价购买，所有资源仅对编程人员及源代码爱好者开放下载做参考和研究及学习，本站不提供任何技术服务!

4、本站所有资源的属示图片和信息不代表本站的立场!本站只是储蓄平台及搬运

5、下载者禁止在服务器和虚拟机下进行搭建运营，本站所有资源不支持联网运行!只允许调试，参考和研究!!!!

6、未经原版权作者许可禁止用于任何商业环境，任何人不得擅作它用，下载者不得用于违反国家法律，否则发生的一切法律后果自行承担!

7、为尊重作者版权，请在下载24小时内删除!请购买原版授权作品，支持你喜欢的作者，谢谢!

8.若资源侵犯了您的合法权益，请持 您的版权证书和相关原作品信息来信通知我们！QQ：1247526623我们会及时删除，给您带来的不便，我们深表歉意!

9、如下载链接失效、广告或者压缩包问题请联系站长处理

10、如果你也有好源码或者教程，可以发布到网站，分享有金币奖励和额外收入!

11、本站资源售价只是赞助，收取费用仅维持本站的日常运营所需

12、因源码具有可复制性，一经赞助，不得以任何形式退款。

13、本文内容由网友自发贡献和站长收集，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系1247526623@qq.com



                        

                            转载请注明出处：
                            慧达安全导航 »
                            RxJava2.x中，如何优雅地在Observable的onComplete回调后取消订阅？
                        

                    

                    



                    


     点赞(0)
    




                    






                    

    

    




                    

    

        
                

            
                

                    Android TextView更新后UI没刷新是什么原因？
                

            
            
Android TextView更新后UI没刷新是什么原因？

        

                

            
                

                    RxJava中：如何在onComplete回调时安全取消Flowable订阅？
                

            
            
RxJava中：如何在onComplete回调时安全取消Flowable订阅？

        

                

            
                

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

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

        

                

            
                

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

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

        

                
    





                    

                
            

                        

                

                    
评论列表                        共有 0 条评论
                    

                

                

                                        

    
    

                
暂无评论