有这样一个页面，每次点击UISegmentedControl的时候就请求一次网络；tableview可以上拉刷新和下拉加载；同时点击UISegmentedControl的时候title切换；
Simulator Screen Shot 2017年2月16日 下午12.51.18.png
1.首先创建网络请求的action
fileprivate func requestAction() -> Action<Bool, Void, NoError> {
return Action<Bool, Void, NoError> { isloadMore in
let index = isloadMore ? (self.pageIndex.value + 1) : 1
return SignalProducer<Void, NoError>({ (obser, dis) in
let armCount = arc4random_uniform(7)
let new = Array(repeating: "new", count: self.counts[Int(armCount)])
DispatchQueue.main.asyncAfter(deadline: .now() + 3, execute: {
if isloadMore {
self.pageIndex.value += 1
var indexPaths: [IndexPath] = []
for (index, _) in new.enumerated() {
let indexpath = IndexPath(row: index + self.dataSource.value.count, section: 0)
indexPaths.append(indexpath)
}
self.dataSource.value += new
self.dataObserver.send(value: .insert(indexPaths))
} else {
self.pageIndex.value = 1
self.dataSource.value = new
self.dataObserver.send(value: .reload)
}
obser.sendCompleted()
})
})
}
}
这个action类型为<Bool, Void, NoError>，它表示接收一个Bool值，表示是否加载更多---(下拉加载时为true)，返回void类型，同时返回NoError的错误类型
为了模拟网络请求，随机获得请求的数据，同时DispatchTime 3s后才发送结果。
当isloadMore即下拉加载更多，接收到数据时，数据变化的观察者发送插入数据的信号
self.dataObserver.send(value: .insert(indexPaths))
当isloadMore 为false，接收到数据时，数据变化的观察者发送重新加载的信号
self.dataObserver.send(value: .reload)
这个是数据变化的观察者属性
fileprivate let dataObserver: Observer<DataProvider, NoError>
/// 数据变化类型枚举
///
/// - reload: 重新加载
/// - insert: 插入数据
enum DataProvider {
case reload
case insert([IndexPath])
}
同时在viewModel 初始化方法里，requestObserver观察requestAction的是否正在活动
action.isExecuting.producer
.start(requestObserver)
然后再vc里添加刷新方法
tableView.mj_header = MJRefreshNormalHeader(refreshingBlock: {
self.request(isLoadMore: false)
})
tableView.mj_footer = MJRefreshBackStateFooter(refreshingBlock: {
self.request(isLoadMore: true)
})
private func request(isLoadMore more: Bool) {
这个时表示viewmodel的action接收外界传入的需求值，然后开始请求
viewModel.action.apply(more).start()
}
extension ViewController {
fileprivate func bind() {
1.首先viewModel的index绑定 segment的selectedIdex
viewModel.index <~ SignalProducer(segment.reactive.selectedSegmentIndexes)
2.点击切换segment的index值时，viewmodel的index会发送信号，在这里进行数据的刷新
viewModel.index.producer
.startWithValues { [unowned self] index in
self.title = self.segment.titleForSegment(at: index)
self.tableView.mj_footer.resetNoMoreData()
self.tableView.mj_header.beginRefreshing()
}
3.观察viewModel的是否正在请求信号
viewModel.requestSignal
.observeValues { isRequest in
self.segment.isEnabled = !isRequest
if !isRequest {
self.stopRequest()
}
}
4.观察viewModel的数据变化信号---如果时reload时，tableview直接reloadData，是insert时，不reloadData，而是tableview insert
viewModel.dataSignal
.observeValues { dataProvider in
switch dataProvider {
case .reload:
self.tableView.reloadData()
case .insert(let indexpaths):
self.tableView.beginUpdates()
self.tableView.insertRows(at: indexpaths, with: .fade)
self.tableView.endUpdates()
}
}
}
}
