RxSwift повторное действие

Question

Я переключаюсь с RAC и хочу иметь повторный сетевой запрос, возвращая разные типы результатов в зависимости от API запроса.

Я хочу использовать интервал, но я не знаю, как совместить возвращаемые типы.

var loop: Observable<Element> { 
    return Observable<Int>.interval(5.0, scheduler: MainScheduler.instance).map { _ in 
     // Do network request and return Observable<Element> 
    } 
} 

Мне нужно вызвать Observerable.interval с типом Int - но return Observable. Как мне это сделать?

Answer 1

Использование flatMap:

var loop: Observable<Element> { 
    return Observable<Int>.interval(5.0, scheduler: MainScheduler.instance).flatMap { _ in 
     return networkRequest() // returns Observable<Element> 
    } 
}