ネットワークコール後にUIRefreshControlにバインドする

Question

私はRxSwiftを初めて使用しています。ターゲットを作成する通常の方法ではなく、UITableViewでUIRefreshControlを「反応的に」使用して手動でとendRefreshing()を呼び出すことができますか？ 。例えば

が、私はAPIからいくつかの文字列をロードしています言う：

class TableViewController: UITableViewController { 

    var data : [String] = [] 

    let db = DisposeBag() 

    override func viewDidLoad() { 
     super.viewDidLoad() 

     refreshControl = UIRefreshControl() 

     //I don't want to use 
     //refreshControl?.addTarget(self, action: #selector(getData), forControlEvents: .ValueChanged) 

     //Do something to refreshControl.rx_refreshing? 
    } 

    override func tableView(tableView: UITableView, cellForRowAtIndexPath indexPath: NSIndexPath) -> UITableViewCell { 
     let cell = tableView.dequeueReusableCellWithIdentifier("Cell", forIndexPath: indexPath) 
     let str = data[indexPath.row] 
     cell.textLabel?.text = str 
     return cell 
    } 

    //MARK: - Requests 

    private func getData() { 
     let myData = MyAPI.getData() //Returns Observable<[String]> 
     myData 
      .subscribe({ [weak self] (event) in 
       switch event { 
       case .Next(let strings): 
        self?.data = strings 
        self?.tableView.reloadData() 
        break 
       case .Error(let err): 
        print(err) 
        break 
       case .Completed: 
        break 
       } 
       // self?.refreshControl?.endRefreshing() 
       }) 
      .addDisposableTo(db) 
    } 
} 

MyAPIは、いくつかの文字列値のための要求を送信し、どのように私は（refreshControlがgetData()を呼び出しても、それが終了していますとき、リフレッシュ停止するように結合することができますまたはerror'd）ネットワーク要求？ refreshControl.rx_refreshingにバインドする必要はありますか？

Answer 1

RxSwiftのアプリケーション例は、この種のロジックを扱う興味深いクラスを提供しています：ActivityIndicator。

ActivityIndicatorを入力すると、rx_refreshingというバインディングのコードが本当に簡単になります。

let activityIndicator = ActivityIndicator() 

override func viewDidLoad() { 
    super.viewDidLoad() 

    refreshControl = UIRefreshControl() 

    // When refresh control emits .ValueChanged, start fetching data 
    refreshControl.rx_controlEvent(.ValueChanged) 
    .flatMapLatest { [unowned self] _ in 
     return self.getData() 
     .trackActivity(activityIndicator) 
    } 
    .subscribeNext { [unowned self] strings in 
     self.data = strings 
     self.tableView.reloadData() 
    } 
    .addDisposableTo(db) 

    // Bind activity indicator true/false to rx_refreshing 
    activityIndicator.asObservable() 
    .bindTo(refreshControl.rx_refreshing) 
    .addDisposableTo(db) 
} 

// getData only needs to return an observable, subscription is handled in viewDidLoad 
private func getData() -> Observable<[String]> { 
    return myData = MyAPI.getData() //Returns Observable<[String]> 
}