Меня интересует, как лучше всего реализовать что-то подобное с библиотекой Play Iteratee:
def sampleEvery[A](i: Int): Enumeratee[A, Int] = ???
таким образом, что при наличии потока A
Enumeratee
будет их подсчитывать и выдавать текущее значение для этого счетчика каждые i
, а затем также добавлять последнее значение (если возможно, без повторения значения).
Например, Enumerator('q','w','e','r','t','y','u','i','o').through(sampleEvery(3))
даст что-то вроде Enumerator(0,3,6,8)
.