Как с помощью Coroutine одновременно запустить два сетевых запроса, используя RxJava?

Синхронизировать выполнение двух Coroutine с помощью RxJava напрямую невозможно, поскольку это две разные парадигмы асинхронного программирования. Coroutine используют suspend-функции и структурированную конкурентность, а RxJava —Observable и операторы.

Однако, если нужно дождаться завершения двух независимых асинхронных операций и продолжить выполнение только после их оба завершения (паттерн "ждать всех"), можно использовать операторы RxJava для объединения результатов или ожидания завершения Observable.

Пример с использованием Coroutine для выполнения сетевых запросов и RxJava для их объединения (с использованием Completable.mergeArray или подобного для ожидания завершения, если сами запросы возвращают Completable, или комбинирования результатов, если возвращают Single или Maybe):

Предположим, у нас есть два suspend-метода, выполняющих сетевые запросы:

kotlin

И мы хотим запустить их параллельно и объединить результаты. Сначала преобразуем suspending-функции в Observable или Single:

kotlin

Теперь используем RxJava операт