使用RxSwift定期更新

Question

我使用以下設置從API中檢索對象（例如GitHub問題）。這工作正常。現在

let provider: RxMoyaProvider<GitHub> 
let issues: Driver<[IssueViewModel]> 

init(provider: RxMoyaProvider<GitHub>) { 
    self.provider = provider 
    issues = provider.request(.Issue) 
       .mapArray(Issue.self, keyPath: "issues") 
       .asDriver(onErrorJustReturn: []) 
       .map { (models: [Issue]) -> [IssueViewModel] in 
        let items = models.map { 
         IssueViewModel(name: $0.name, 
          description: $0.description 
        ) 
        } 
        return items 
       } 
} 

我想定期更新的問題（例如，每20秒）的列表。我想到了一個NSTimer來完成這項任務，但我想可能有一個我沒有考慮的乾淨（呃）解決方案（即以Rx方式）。

任何暗示正確的方向是高度讚賞。

Answer 1

這是非常相似的this question/answer。

您應該使用timer然後flatMapLatest：

Observable<Int>.timer(0, period: 20, scheduler: MainScheduler.instance) 
    .flatMapLatest { _ in 
     provider.request(.Issue) 
    } 
    .mapArray(Issue.self, keyPath: "issues") 
    // ... 

Answer 2

您可能正在尋找interval運營商。 以下是interval的循環示例，它會每秒鐘繼續打印「測試」。 鏈接到文件：http://reactivex.io/documentation/operators/interval.html

var driver: Driver<String> { 
     return Driver<Int>.interval(1.0).map { _ in 
      return "test" 
     } 
    } 
    driver.asObservable().subscribeNext { (variable) in 
     print(variable) 
    }