Akka Stream,功能来源？

Question

我希望有一个Source以给定的间隔评估函数并发出其输出.作为一种解决方法,我可以使用Source.queue+ 来完成它offer,但还没有找到更简洁的方法.理想情况下,我会有类似的东西

def myFunction() = ....                     // function with side-effects 
Source.tick(1.second, 1.second, myFunction) // myFunction is evaluated at every tick

有任何想法吗？

Answer 1

可能最干净的方法是使用 map

Source.tick(1.second, 1.second, NotUsed).map(_ ? myFunction())