Всем привет. Можно ли в мониксе как-то "перезарядить" observable, после

Question

Всем привет. Можно ли в мониксе как-то "перезарядить" observable, после

того, как предыдущая пачка данных прошла через весь стрим? Допустим тут:
Observable.fromIterable(List(1,2,3))
...
.consumeWith(Consumer.foreach(...))
Пытаюсь как-то использовать комбинацию различных repeat и и буфферов, но не могу придумать как заставить observable подождать когда закончит обрабатываться предыдущий лист

#programming #russian #scala

0

20.08.2018