使用 flatMapLatest 处理错误并重试

Question

我有一个网页，其中有很多用户可以单击的项目。单击任何项目，根据其类型，将向服务器发送 ajax 请求，然后显示更多项目。如果请求导致错误，我想显示它，然后允许用户像以前一样继续单击或与页面交互。

我的代码是这样的

$scope.$createObservableFunction("clickHandler")
    .flatMapLatest(function (args) {
        //send the ajax request to the server
    })
    .retry()
    .subscribe(function (data) {
         //handle getting the data from the server
    })

我在哪里可以处理错误情况？我预计会发生错误，并且我一直想重新订阅源，但我希望有机会处理该错误。

Answer 1

诀窍是将错误转化为数据：

$scope.$createObservableFunction("clickHandler")
    .flatMapLatest(function (args) {
        //send the ajax request to the server
        var ajaxQuery = someObservable;

        // turn the observable into
        // a stream of eithers, which will
        // either have a 'result'
        // or an 'error'
        // use .catch() to turn the error
        // into a either with an error property
        // use .map() to turn the success
        // into a either with the result property
        return ajaxQuery
            .map(function (result) {
                return { result: result };
            })
            .catch(function (error) {
                return Rx.Observable.of({ error: error });
            });
    })
    .subscribe(function (data) {
         if (data.error) {
            // display data.error to user
         }
         else {
            // display data.result to user
         }
    })

如果您的 ajax 方法 returns a Promise，请使用 then 链接：

$scope.$createObservableFunction("clickHandler")
    .flatMapLatest(function (args) {
        //send the ajax request to the server
        var ajaxQuery = somePromise;

        // turn the promise into
        // a promise of eithers, which will
        // either have a 'result'
        // or an 'error'
        return ajaxQuery
            .then(function onSuccess(result) {
                return { result: result };
            }, function onError (error) {
                return { error: error };
            });
    })
    .subscribe(function (data) {
         if (data.error) {
            // display data.error to user
         }
         else {
            // display data.result to user
         }
    })

使用 flatMapLatest 处理错误并重试

handling errors with flatMapLatest and retry

javascript

reactive-extensions-js

rxjs