RxSwift重复动作

bes*_*der 4 swift rx-swift

我正在从RAC切换并希望重复网络请求,根据请求的API返回不同的结果类型.

我想使用一个间隔,但我不知道如何匹配返回类型.

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

我需要使用Int - 类型调用Observerable.interval,但返回Observable.我该怎么办?

Evg*_*eev 9

使用flatMap:

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

  • 将订阅存储在变量中,并在不需要时使用`dispose()`进行处理. (3认同)