1

我正在学习 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)
        }
}
4

0 回答 0