При переходе с MVP на MVI очень спасает мини-библиотека kotlinx.coroutines.rx2.

Проект старый, весь код работающий с API в основном возвращает Rx-сущности. А методы Middleware в котором как раз мы и дергаем этот API, возвращает flow.

Поток данных внутри flow-билдера должен быть синхронным, что как раз и позволяет сделать эта маленькая библиотечка, добавляющая метод-расширение await() к SingleSource/CompletableSource/MaybeSource и тд. Внутри расширения используется блок suspendCancellableCoroutine, который оборачивает каллбеки Rx, возвращая результат.

В итоге, код будет выглядеть примерно так:

val response = interactor.apiRequest().await()

Крайне рекомендую, если у вас все еще смешанное использование Coroutines/Rx.

#MVI #Coroutines #Rx