RXAlamofire 不返回数据（错误与否）

Question

这是我的非反应性代码，运行良好。

func getLatestHtml2(){

Alamofire.request("https://www.everfest.com/fest300").responseString { response in
    print("\(response.result.isSuccess)")
    if let html = response.result.value {
        self.parseHTML(html: html)
    }
}

}

但是，当我使用此代码使其具有反应性时。

  func getLatestHtml1() -> Observable<String> {

        return Observable<String>.create { (observer) -> Disposable in
            let request = Alamofire
                .request("https://www.everfest.com/fest300")
                .responseString { response in
                    print(response.result.value)
                    observer.onNext(response.result.value!)
                    observer.onCompleted()

            }
            return Disposables.create { request.cancel() }


        }
    }

我在打印语句中没有得到任何数据。我什至使用了 RxAlamofire，我觉得这是使用这段代码的正确方法，而且它有错误检查功能：

func getLatestHtml() -> Observable<String?> {
        return RxAlamofire

            .requestData(.get,"https://web.archive.org/web/20170429080421/https://www.everfest.com/fest300" )
            .debug()
            .catchError { error in
                print(error)
                return Observable.never()
            }
            .map { (response, value) in
                print(response.statusCode)
                guard response.statusCode == 200 else { return nil }
                print(value)
                return String(data: value, encoding: String.Encoding.utf8)
            }
            .asObservable()



    }

在任何地方都没有产生任何数据或错误。我需要知道是我的语法错误还是我对反应式编程的想法是错误的。

我将其称为 .getLatestHTMLX()。谢谢！

Answer 1

Observable 是惰性的，除非有人监视它们，否则它们不会做任何工作（并且通常会在没有人监视时立即停止工作。）这意味着您必须订阅一个 observable 才能启动发射值。

此外，除非您明确共享可观察对象，否则它将为每个订阅者启动一个新请求。

RXAlamofire 不返回数据（错误与否）

RXAlamofire not returning data ( error or not)

frp

reactive-programming

swift

rx-swift

rxalamofire