首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >在数据库中存储订阅Mono时的Disposable

在数据库中存储订阅Mono时的Disposable
EN

Stack Overflow用户
提问于 2017-12-07 17:59:29
回答 0查看 823关注 0票数 0

我目前正在探索reactor-core。我能够订阅一个单声道,也可以节省一次性处理执行的订阅者。

代码语言:javascript
复制
Mono<Object> task1 = Mono.just("Task1");
Mono<Object> task2 = Mono.just("Task2");
System.out.println(System.currentTimeMillis());
HashMap<Mono,Disposable> taskHandlerMap = new HashMap<>();
Disposable task1Handler = task1.delayElement(Duration.ofSeconds(5)).subscribe(
(Object x)->{
        System.out.println(x.toString() + "\t" + System.currentTimeMillis());
});
taskHandlerMap.put(task1,task1Handler);
Disposable task2Handler = task2.delayElement(Duration.ofSeconds(10)).subscribe(
(Object x)->{
        System.out.println(x.toString() + "\t" + System.currentTimeMillis());
});
taskHandlerMap.put(task2,task2Handler);

我能够通过使用处理程序映射来处理计划的任务,如下所示。

代码语言:javascript
复制
taskHandlerMap.get(task2).dispose();

我可以将此taskHandlerMap保存在数据库中吗?是,我怎样才能保存它。否则,有没有更好的方法来存储订阅时创建的一次性文件。

EN

回答

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/47692305

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档