3

嗨，我正在尝试使 UIRefreshControl 与 RxSwift 一起工作。因此，我使用的是 RxSwift 示例中的活动指示器。

在我的 viewModel 中，我有以下函数和变量来获取我的数据。

// MARK: - Variables

var data = Variable<[Data]>([])

// MARK: - Public Interface

func getData() {
    let request = Data.readAll()
    _ = request.rxResult().subscribe(onNext: { response in
        self.data.value = response.data
    }, onError: { (Error) in
    }, onCompleted: {
    }, onDisposed: {
    })
}

然后在我的视图控制器中，我尝试将它绑定到 UIRefreshcontrol 和我拥有的集合视图。

let refresher: UIRefreshControl = UIRefreshControl()
let indicator = ActivityIndicator()

    indicator.asObservable()
    .bindTo(refresher.rx.isRefreshing)
    .addDisposableTo(disposeBag)

    let resultObservable = viewModel.data.asObservable()
        .trackActivity(indicator)
        .bindTo(self.collectionView.rx.items(cellIdentifier: reuseCell, cellType: DataCollectionViewCell.self)) {
            row, data, cell in
            cell.configureCell(with: data)
        }
    resultObservable.addDisposableTo(disposeBag)

我的问题是，我缺少什么来完成这项工作？现在，如果我启动应用程序，除了一个不停旋转的黑色活动指示器之外，什么也没有发生。

4

2 回答 2

2

我认为您应该更喜欢在 ViewController 中订阅并将该订阅添加到该视图控制器的处置包中。

我认为以下方式是使用 RxExamples 中的 ActivityIndi​​cator 的正确方式。以下是伪代码。

/// ViewController.swift
 import RxSwift
 import RxCocoa
…
 let refreshControl = UIRefreshControl()
 refreshControl.rx.controlEvent(.valueChanged)
        .bind(to:self.viewModel.inputs.loadPageTrigger)
        .disposed(by: disposeBag)
 self.viewModel.indicator
    .bind(to:refreshControl.rx.isRefreshing)
    .dispose(by:disposeBag)
…

/// ViewModel.swift
…
let loadTrigger = PublishSubject<Void>()
let indicator = ActivityIndicator().asDriver()
…
// Assuming rxResult returns Observable<Response>
let req = indicator.asObservable()
    .sample(loadTrigger)
    .flatMap { isLoading -> Observable<Response> in 
         if isLoading { return Observable.empty() }
    return Data.readAll().rxResult()
}
.trackActivity(indicator)
.map { $0.data }
.do(onNext: { [unowned self] data in
    self.data.value = data
})
…
于 2018-02-26T02:09:16.783 回答
0 
refresher
        .rx.controlEvent(UIControlEvents.valueChanged)
        .subscribe(onNext: { [weak self] in
    //Put your hide activity code here
            self?.refresher.endRefreshing()
            }, onCompleted: nil, onDisposed: nil)
        .disposed(by: disposeBag)

订阅刷新事件(UIRefreshControl)

于 2018-02-20T08:22:44.427 回答