RXSwift -如何召回api

Question

我为api调用创建了一个可观察的，并绑定到一个tableview。现在我不清楚如何再次调用相同的api？以便进行刷新--例如按一下按钮？下面是我的示例代码。

请告诉我你的想法，这会有帮助的

 var items : Observable<[String]>? 
   func viewDidLoad(){

            items = fetchAllAnswers()
          items.bindTo(....).addDisposableTo(bag)
    }
   func fetchAllAnswers() -> Observable<[String]>{
   let api = Observable.create { (obsever: AnyObserver<[String]>) -> Disposable in
        let answers = API.allAnswers()
                     obsever.onNext(answers)
                     obsever.onCompleted()
                    return AnonymousDisposable{
                        print("api dispose called")
                    }
                }
                return api

            }

    func onClickRefresh()
   {
   // how to call api here again?


   //  let items = fetchAllAnswers() 
    // items.bindTo(....).addDisposableTo(bag)

   }

Answer 1

这很简单。您可以使用变量来更新项目：

let items =  Variable([String]())

接下来，必须将项与UITableView绑定：

items.asObservable.bindTo(....).addDisposableTo(bag)

接下来，您可以在订阅服务器中更新您的项目：

fetchAllAnswers()
.subscribeNext { stringArray in 
    items.value = stringArray
}
.addDisposableTo(bag)

如果您想按一下按钮更新您的表，您可以执行以下操作：

yourButton.rx_tap
.flatMap { void -> Observable<[String]> in
    return fetchAllAnswers()
}
.subscribeNext { stringArray in 
    items.value = stringArray
}
.addDisposableTo(bag)

Answer 2

func viewDidLoad() {
  button.rx_tap.startWith().flatMap { _ in
    fetchAllAnswers()
  }.bindTo(...).addDisposableTo(bag)
}

flatMap将把抽头转换为可观察到的闭包返回的结果，这里是一个String数组。

startWith()将强制rx_tap在订阅时发出第一个值，以便保持第一次刷新行为。