| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | api()?.subscribe(onNext: { data in |
|---|
| | | if let datas = data.data,datas.count > 0{ |
|---|
| | | if let datas = data.data{ |
|---|
| | | switch status{ |
|---|
| | | case .refresh: |
|---|
| | | self.dataSource.accept(datas) |
|---|
| | | self.refreshSubject.onNext(.completedRefresh) |
|---|
| | | case .load: |
|---|
| | | self.dataSource.accept(self.dataSource.value + datas) |
|---|
| | | self.refreshSubject.onNext(.completedLoad) |
|---|
| | | if datas.count == 0{ |
|---|
| | | self.refreshSubject.onNext(.completedLoadWithNoMoreData) |
|---|
| | | }else{ |
|---|
| | | self.refreshSubject.onNext(.completedLoad) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | self.refreshSubject.onNext(.completedLoadWithNoMoreData) |
|---|
