基于时间的处理

很多时候我们都想限制上游发送元素到下游的(生产)速度,Akka Streams内建了对此的支持。通过Flow.throttle的各个版本提供了多种策略的限流功能。

Source
  .fromIterator(() => Iterator.from(0))
  .throttle(5, 500.millis)

throttle限制每500毫秒内最多只生产5个元素(可发送5个到下游)。

在此文档中发现错误?该页面的源代码可以在 这里 找到。欢迎随时编辑并提交Pull Request。