Блокчейн в RxKotlin и продолжить

У меня есть операция цепочки в моем приложении, где у меня есть список некоторых данных, я буду перебирать список с iteratable observable после завершения итерации, я выполню другую операцию, которая не зависит от предыдущего списка, так что мне нужно находится между этими двумя операциями, мне нужно заблокировать (или заблокировать), пока первая не завершится, и перейти ко второй.

Пример

Observable.fromIterable(listOf("A","B","C","D"))
          .map{
            doSomeTask(it)
          } 
   // I need a blocking here, once this iteration completes i will proceed with the below task, but i don't need of toList() to block since i don't want the data,       
          .map{
            doSomeOtherTask()
          }

Кто-нибудь может мне с этим помочь?


android kotlin rx-java2 rx-kotlin2
person Stack    schedule 14.05.2019    source источник

Ответы (2)


arrow_upward
0
arrow_downward

Используйте doOnNext, если вы хотите распространить каждое из значений, или doOnComplete, если хотите что-то сделать в конце итерации.

person Tassos Bassoukos    schedule 14.05.2019

arrow_upward
0
arrow_downward

Что вы могли бы сделать, это ниже:

Observable.fromIterable(listOf("A", "B", "C", "D"))
        .subscribeBy(
            onNext = {
                doSomeTask(it)
            },
            onComplete = {
                doSomeOtherTask()
            }
        )

Так вы добьетесь ожидаемого результата. Ваше здоровье!

person r2rek    schedule 14.05.2019