Я хочу создать Enumeratee для Play 2, который принимает значения и выводит их, разбивая их на куски, каждыйx секунды / миллисекунд. Таким образом, в многопользовательской среде веб-сокетов с большим количеством пользовательского ввода можно ограничить количество принимаемых кадров в секунду.

Я знаю, что этоМожно сгруппировать определенное количество элементов следующим образом:

val chunker = Enumeratee.grouped(
  Traversable.take[Array[Double]](5000) &>> Iteratee.consume()
)

Есть ли встроенный способ сделать это, основываясь на времени, а не на количестве предметов?

Я думал о том, чтобы сделать это как-то с запланированной работой Akka, но на первый взгляд это кажется неэффективным, и я 'Я не уверен, возникнут ли проблемы с параллелизмом.