handle(requests: Observable[Req]): Observable[Resp]
когда в зависимости от элементов в Resp надо докидывать новые реквесты в requests или остановить его?
Или может лучше как-то по-другому это делать?
Спасибо.
подписчик же решает когда остановиться, и когда он закончил
да, я дошел до варианта сделать requests subject'ом, от респонза сделать responses.mapFuture { case n: Next => requests.onNext(func(n)).map(Right.apply)) case s: Stop => Left(s) }.takeUntil { case Left => true case _ => false }.lastL но чет криво как-то
Обсуждают сегодня