我想要一个 Source 以给定的时间间隔评估一个函数并发出它的输出。作为一种解决方法，我可以使用 Source.queue 来实现。 + offer ，但还没有找到更干净的方法来做到这一点。理想情况下，我会有类似的东西
def myFunction() = .... // function with side-effects
Source.tick(1.second, 1.second, myFunction) // myFunction is evaluated at every tick
有任何想法吗？
最佳答案
可能最干净的方法是使用 map
Source.tick(1.second, 1.second, NotUsed).map(_ ⇒ myFunction())
关于scala - Akka Stream，来自功能的来源？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/43590101/