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) 
    }