scala – 如何减缓Akka-Streams中的制作人

发布时间：2020-12-16 18:08:37 所属栏目：安全来源：网络整理

导读：我试图解决akka-streams的问题.我希望我的初始生产者不断获取队列/ mongodb集合并在配置的时间间隔内完成.实现它的常见做法是什么？解决方法你的意思是固定的时间间隔？从Source.tick(…)开始.map(loadFromMongo)？如果这是您想要的,请放入conflate that

我试图解决akka-streams的问题.我希望我的初始生产者不断获取队列/ mongodb集合并在配置的时间间隔内完成.实现它的常见做法是什么？

解决方法

你的意思是固定的时间间隔？

从Source.tick(…)开始.map(loadFromMongo)？

如果这是您想要的,请放入conflate that drops ticks以防止比下游更频繁地查询数据库.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!