Как подписаться на два observable разного типа за раз? rxjava
У меня есть два observable разного типа.
val urlContent = contentRepo.getUrlContent(urls).toObservable()
val isConnected = Observable.interval(1, TimeUnit.SECONDS).flatMap {
internetConnectionRepo.isInternetOnline()
}
urlContent типа Observable<List<String>>,
а isConnected типа Observable<Boolean>.
Мне нужно сделать так, чтобы isConnected действовал, пока не получу urlContent. При этом, это всё находится в usecase, который должен вернуть List<String>. Я пробовал написать:
return isConnected.takeUntil(urlContent)
Но тогда usecase возвращает Observable<Boolean>.
Как я могу получить результат urlContent?