timeout

签名: timeout(due: number, scheduler: Scheduler): Observable

在指定时间间隔内不发出值就报错

timeout - 图1

示例

示例 1: 2.5秒后超时

( jsBin |
jsFiddle )

  1. import { of } from 'rxjs/observable/of';
  2. import { concatMap, timeout, catchError } from 'rxjs/operators';
  4. // 模拟请求
  5. function makeRequest(timeToDelay) {
  6.   return of('Request Complete!').pipe(delay(timeToDelay));
  7. }
  9. of(4000, 3000, 2000)
  10.   .pipe(
  11.     concatMap(duration =>
  12.       makeRequest(duration).pipe(
  13.         timeout(2500),
  14.         catchError(error => of(`Request timed out after: ${duration}`))
  15.       )
  16.     )
  17.   )
  18.   /*
  19.     *  "Request timed out after: 4000"
  20.     *  "Request timed out after: 3000"
  21.     *  "Request Complete!"
  22.     */
  23.   .subscribe(val => console.log(val));

其他资源

:file_folder: 源码:
https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/timeout.ts