работает, то как будет верно менять Dispatcher для промежуточных операций? Ну т.е. какой аналог будте такого кода RxJava
state: BehaviorProcessor
state
.observeOn(Schedulers.IO)
.doOnNext(Do something in IO thread)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(Do something in main thread)
flowOn меняет поток исполнения в операторах выше по цепочке, а collect будет выполняться в потоке, который используется в scope.launch {}
Обсуждают сегодня