RxSwift，调用网络调用

Question

我是Rx的新手，正在尝试一个网络呼叫。

我设法做到如下：

struct Genre: Codable {
var genres: [Genres]?
}
struct Genres: Codable {
var id: Int?
var name: String?
}
final class GenreViewModel {
let disposeBag = DisposeBag()
var networking: Networking!
let getGeners = PublishRelay<[Genres]>()
var items: PublishRelay<[Genres]>?
var itemsDriver: Driver<[Genres]>?
let isLoading: Driver<Bool>

init(networking: Networking = Networking()) {
self.networking = networking

let shouldLoadItems = Observable.merge(
).debug("merge.debug(🚘)")
.startWith(())

let gg = shouldLoadItems.flatMap {
networking.preformNetwokTask(
endPoint: TheMoviedbApi.genre,
type: Genre.self)
.debug("🚘 network call")
}

isLoading = Observable.merge(
shouldLoadItems.map { true },
gg.map { _ in false }
)
.asDriver(onErrorJustReturn: false).debug("🚘 is loading")

itemsDriver = gg
.map { $0.genres! }
.asDriver(onErrorJustReturn: []).debug("🚘drive")

}

我正试图找到一种不用"；let shouldLoadItems"；。类似的东西：

final class GenreViewModel {
let disposeBag = DisposeBag()
var networking: Networking!
let getGeners = PublishRelay<[Genres]>()
var items: PublishRelay<[Genres]>?
var itemsDriver: Driver<[Genres]>?
let isLoading: Driver<Bool>

init(networking: Networking = Networking()) {
self.networking = networking

let geners =  getGeners
.flatMap { geners in
networking.preformNetwokTask(
endPoint: TheMoviedbApi.genre,             
type: Genre.self)
.debug("🚘 network call not in use")
}.startWith(())
.share()


isLoading = Observable.merge(
shouldLoadItems.map { true },
gg.map { _ in false }
)
.asDriver(onErrorJustReturn: false).debug("🚘 is loading")

itemsDriver = geners
.map { $0.genres! }
.asDriver(onErrorJustReturn: []).debug("🚘drive")

}

vc:

func bindRx() {
viewModel.isLoading
.drive(hud.rx.animation)
.disposed(by: disposeBag)



viewModel.itemsDriver?.drive(collectionView.rx.items(cellIdentifier: GenreCollectionViewCell.reuseIdentifier, cellType: GenreCollectionViewCell.self)) { (row,item,cell) in
cell.config(item: item)
}.disposed(by: disposeBag)
}

然而，让将军们不要打电话。我错过了什么？

Answer 1

我想评论中的所有问题都有点痛苦，但这个问题缺少的是"反应性"；部分"；功能反应编程"；。

在FRP中，网络请求不会孤立地发生。它通常由事件生产者触发，并为事件消费者提供信息。为了使请求发生，必须存在事件使用者。

视图模型本身并没有连接到任何东西，它什么也不做。为了让你的网络事件发生，必须有的东西在监听结果。你的视图模型就像你房子里的水管。除非有人打开水龙头，否则水就不会流。

struct GenreViewModel {
let items: Observable<[Genres]>
let error: Observable<Error>
let isLoading: Observable<Bool>
init(networking: Networking) {
let result = networking.preformNetwokTask(endPoint: TheMoviedbApi.genre, type: Genre.self)
.compactMap(.genres)
.materialize()
.share(replay: 1)
items = result
.compactMap { $0.element }
error = result
.compactMap { $0.error }
isLoading = result
.map { _ in false }
.startWith(true)
}
}
final class GenreViewController: UIViewController {
var tableView: UITableView!
var activityIndicatorView: UIActivityIndicatorView!
var viewModel: GenreViewModel!
let disposeBag = DisposeBag()
override func viewDidLoad() {
super.viewDidLoad()
viewModel.items
.bind(to: tableView.rx.items(cellIdentifier: "Cell")) { _, genres, cell in
cell.textLabel?.text = genres.name
}
.disposed(by: disposeBag)
viewModel.error
.bind(onNext: presentScene(animated: true) {
UIAlertController(title: "Error", message: $0.localizedDescription, preferredStyle: .alert)
.scene { $0.connectOK() }
})
.disposed(by: disposeBag)
viewModel.isLoading
.bind(to: activityIndicatorView.rx.isAnimating)
.disposed(by: disposeBag)
}
}

在上面的代码中，一旦执行了bind调用，网络请求就会启动。如果发出错误，它将被路由到errorObservable，并将显示带有错误消息的UIAlertController(它使用CLE架构工具来执行此操作。(如果成功，流派对象的名称将显示在表视图中。