его сделать с exp backoff, чтоб не обращаться к апи слишком часто?
и с другой стороны, если в сорсе есть данные, то извлекаем максимально быстро
так объявлен если
val filesIterator = Iterator.iterate[Option[File]](None)(_ => api.takeFile())
Source
.fromIterator(() => filesIterator)
https://doc.akka.io/docs/akka/2.5/stream/stream-cookbook.html#adhoc-source
Обсуждают сегодня