swift - 删除 Swift RxAlamofire 依赖项

Question

我正在尝试消除对 RxAlamofire 的依赖。

我目前有这个功能：

  func requestData(_ urlRequest: URLRequestConvertible) -> Observable<(HTTPURLResponse, Data)> {

    RxAlamofire.request(urlRequest).responseData()

  }

我该如何重构它并直接使用 Alamofire 来构建和返回 RxSwift Observable？

Answer 1

我建议您查看库包装 URLRequest 的方式，以了解如何执行此操作...

下面是库中的一个简短示例。本质上，您需要使用Observable.create, 使网络调用传入一个知道如何使用create给您的观察者的闭包。

确保在完成后发送完成，并确保一次性知道如何取消请求。

您Base将在 Alamofire 中有所作为（我不使用 Alamofire，所以我不确定那可能是什么。）

extension Reactive where Base: URLSession {
    /**
    Observable sequence of responses for URL request.
    
    Performing of request starts after observer is subscribed and not after invoking this method.
    
    **URL requests will be performed per subscribed observer.**
    
    Any error during fetching of the response will cause observed sequence to terminate with error.
    
    - parameter request: URL request.
    - returns: Observable sequence of URL responses.
    */
    public func response(request: URLRequest) -> Observable<(response: HTTPURLResponse, data: Data)> {
        return Observable.create { observer in
            let task = self.base.dataTask(with: request) { data, response, error in
                guard let response = response, let data = data else {
                    observer.on(.error(error ?? RxCocoaURLError.unknown))
                    return
                }

                guard let httpResponse = response as? HTTPURLResponse else {
                    observer.on(.error(RxCocoaURLError.nonHTTPResponse(response: response)))
                    return
                }

                observer.on(.next((httpResponse, data)))
                observer.on(.completed)
            }

            task.resume()

            return Disposables.create(with: task.cancel)
        }
    }
}