ios - 使用 RxAlamofire 创建 Observable 包含网络请求的结果
<p><p>我正在尝试使用 <code>RxAlamofire</code> 来包装网络请求结果。</p>
<p>我的目标是触发请求、处理 JSON 响应并创建包含网络操作成功或发生任何错误的 Observable。</p>
<p>在其他地方，我可以调用创建 Observable 的函数并订阅它，并通过错误消息通知用户它是成功还是失败。</p>
<p>我的实现如下:</p>
<pre><code>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))
}
}
</code></pre>
<p>我们如何更正代码以及如何从其他地方调用它以通知处理结果？</p></p>
<br><hr><h1><strong>Best Answer-推荐答案</ strong></h1><br>
<p><p>Observable 定义多个生命周期回调，您使用 <code>subscribe</code> 方法提供。在这种情况下，用法是这样的:</p>
<pre><code>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)
</code></pre>
<p><code>disposeBag</code> 用于保存订阅，所以当 disposeBag 被释放时，订阅被取消(在我们的例子中，网络调用将被中止)。</p></p>
<p style="font-size: 20px;">关于ios - 使用 RxAlamofire 创建 Observable 包含网络请求的结果，我们在Stack Overflow上找到一个类似的问题：
<a href="https://stackoverflow.com/questions/43236932/" rel="noreferrer noopener nofollow" style="color: red;">
https://stackoverflow.com/questions/43236932/
</a>
</p>
页:
[1]