swift - RxSwift 和 Alamofire : can't subscribe events after alamofire handling response data

Question

这是我的一些代码:

func toObservable() -> Observable<T> {
    return Observable.create {
        observer -> Disposable in
        let urlRequest = try? self.asURLRequest()

        Alamofire.request(urlRequest!)
            .responseObject{ (response: DataResponse<T>) in
                if response.result.isSuccess {
                    if let responseEntity = response.result.value {
                        if let _ = responseEntity.error {
                            observer.onError(ResponseError.generic)
                        } else {
                            observer.onNext(responseEntity)
                        }
                    } else {
                        // TODO
                    }
                } else {
                    // TODO
                }
        observer.onCompleted()

        }

        return Disposables.create()
    }
}

当我调用这个函数时:

toObservable().subscribe(onNext: {
            print("onNext")
            // ... use $0 parameter
        }, onError: {
            print("onError")
            // ... use $0 parameter
        }, onCompleted: { 
            print("onCompelete")
        }, onDisposed: nil)
    .addDisposableTo(DisposeBag())

它只是不能打印任何东西。那么对此有什么想法吗？非常感谢!

(我使用了 AlamofireObjectMapper、RxSwift 框架)

同样的问题是here但没有人回答。

Answer 1

尝试像这样保持对 disposbag 的强引用:

let disposeBag = DisposeBag()

func setupRx() {

  toObservable()
      .debug("Alamofire.request")
      .subscribe(onNext: {
          print("onNext")
        // ... use $0 parameter
      }, onError: {
          print("onError")
        // ... use $0 parameter
      }, onCompleted: { 
          print("onCompelete")
      }, onDisposed: nil)
  .addDisposableTo(disposeBag)

}

并且您可以使用 debug 运算符来查看发生了什么。

希望这可能有所帮助。