使用RxJS处理超时

用户进行一个操作请求后台而长时间未响应，我们希望给用户一个信息展示（请求超时，网络不好...）. 关于RxJS请看这里我这个功能的实现主要使用 **delay**，**race**两个操作符。 * **delay** 通过给定的超时或者直…

使用RxJS处理超时

使用场景

用户进行一个操作请求后台而长时间未响应，我们希望给用户一个信息展示（请求超时，网络不好...）.

RxJS实现

关于RxJS请看这里

我这个功能的实现主要使用 delay，race两个操作符。

delay 通过给定的超时或者直到一个给定的时间来延迟源 Observable 的发送。延迟时间(以毫秒为单位的数字)或 Date 对象(发送延迟到这个时间点)。
race 返回 Observable，该 Observable 是源 Observable 和提供的 Observables 的组合中第一个发出项的 Observable 的镜像。

具体实现过程代码（使用angualr和ionic）如下：我封装成了service方便使用。主要看timeoutDeal方法。 service.ts

text

import { Injectable } from "@angular/core";
import { delay, map, race } from "rxjs/operators";
import { Observable } from "rxjs/Observable";
import { AlertController, LoadingController } from "ionic-angular";

@Injectable()
export class HttpTimeoutService {
    loading: any;
    timer: any;
    timers:any[]=[];
    constructor(private loadingCtrl: LoadingController,
                private alertCtrl: AlertController) {
    }

    // **参数name和参数mes相同
    showLoading(name) {
        const self = this;
        let obj={name:name,timer:undefined,loading:undefined};
        const timer = setTimeout(() => {
            let loading = this.loadingCtrl.create();
            loading.present();
            obj.loading=loading;
        }, 500);
        obj.timer=timer;
        this.timers.push(obj);
    }

    clearTimer(name) {
        const self = this;
        for(let i=0;i<this.timers.length;i++){
            if(this.timers[i].name===name){
                if(this.timers[i].loading){
                    this.timers[i].loading.dismiss();
                }
                clearTimeout(this.timers[i].timer);
                this.timers.splice(i,1);
                return;
            }
        }
    }

    timeoutDeal(mes) {
        const self = this;
        let TIME_OUT = 6000;
        let cancel$ = Observable.of(null).pipe(delay(TIME_OUT),
            map(_ => {
                // throw 'error';

                self.clearTimer(mes);
                self.alertCtrl.create({
                    title: '连接超时',
                    message: '当前网络不稳定，请寻找一个稳定网络！',
                    buttons: ['确定']
                }).present();
                throw mes + 'timeout!'
            }));
        return cancel$;
    }

}

pipe是 Observable 中有一个内置的 pipe 方法 (Observable.prototype.pipe)，它可以用类似于之前的链式调用的方式来组合操作符。RxJS 5.5版本之后。

RxJS