результатом? почему всякие редьюсы и фолды стопят выполнения где-то не там? неужели надо писать свой субскрайбер для такой простой штуки?
scan
Писать обзёрваблы легко и приятно
чо ты хочешьоб ъясни
import akka.stream._ import akka.stream.scaladsl._ Source.fromPublisher(observable.toReactivePublisher).toMat(Sink.fold(0)(_ + _))(Keep.right).run()
Обсуждают сегодня