ios - 使用 RxAlamofire 创建包含网络请求结果的 Observable

Question

我正在尝试使用 RxAlamofire 来包装网络请求结果。

我的目标是触发请求、处理 JSON 响应并创建包含网络操作成功或发生任何错误的 Observable。

在其他地方，我可以调用创建 Observable 的函数并订阅它，并通过错误消息通知用户它是成功还是失败。

我的实现如下:

func discoverMovieList(for url: String, withPagg page: Int) -> Observable<Any> {
        let requestUrl = "\(url)&page=\(page)"

        return RxAlamofire.json(.get, requestUrl)
            .map{ jsonResponse in
                    self.createOrUpdateMoviesList(from: JSON(jsonResponse))
                }
    }

我们如何修改代码以及如何从其他地方调用它来通知处理结果？

Answer 1

Observable 定义多个生命周期回调，您使用 subscribe 方法提供。在这种情况下，用法将是这样的:

discoverMovieList(for: "http://some.url", withPagg: 2)
  .subscribe(
    onNext: { movies in
      uiElement.string = "Movie list received"
    },
    onError: { error in
      uiElement.string = "Something went wrong"
    }
  )
  .disposed(by: disposeBag)

disposeBag 用于保存订阅，因此当释放 disposeBag 时，订阅将被取消(在我们的例子中，网络调用将被中止)。