我正在尝试解决一个Akka Streams的问题。我希望我的初始生产者能够在配置的时间间隔内不断地获取队列/ MongoDB集合。实现这一目标通常采用哪种方法?
我正在尝试解决一个Akka Streams的问题。我希望我的初始生产者能够在配置的时间间隔内不断地获取队列/ MongoDB集合。实现这一目标通常采用哪种方法?
此外,还有一个叫做“节流”的概念。可以按照以下方式使用:
Source(...).throttle(50, 1.second, 1, ThrottleMode.Shaping)