| | |
| | | private var handle:UIScrollView! |
| | | |
| | | lazy var refreshSubject = PublishSubject<RefreshState>() |
| | | var page:Int = 0 |
| | | var page:Int = 1 |
| | | var pageSize:Int = 20 |
| | | private var needRefreshData:Bool = true |
| | | lazy var dataSource = BehaviorRelay<[T]>(value: []) |
| | |
| | | } |
| | | |
| | | func beginRefresh(){ |
| | | handle.mj_header?.beginRefreshing() |
| | | guard handle != nil else {return} |
| | | api()?.subscribe(onNext: { data in |
| | | if let datas = data.data{ |
| | | self.dataSource.accept(datas) |
| | | self.refreshSubject.onNext(.completedRefresh) |
| | | } |
| | | }).disposed(by: disposeBag) |
| | | } |
| | | |
| | | func refreshData() ->(()->Void) { |