我正在学习 RxAlamofire,我遇到了以下问题:在 onNext 的这段代码片段中,onError 和 onCompleted 没有被调用,好像订阅根本不起作用。比较一下,一段代码与普通的 Alamofire 工作得很好。
private func test() {
let disposeBag = DisposeBag()
Observable.from(["1", "2", "3"])
.subscribe(onNext: {
print("\($0) lol")
})
.disposed(by: disposeBag)
let observable: Observable<(HTTPURLResponse,Any)> =
RxAlamofire.requestJSON(.get, "https://api.fixer.io/latest?base=EUR&symbols=USD")
.debug()
observable
.subscribe(
onNext: { [weak self] (r, json) in
print(json)
}, onError: {
print($0)
})
.addDisposableTo(disposeBag)
Alamofire.request("https://api.fixer.io/latest?base=EUR&symbols=USD")
.responseJSON {
print($0)
}
}