如何扩展rxjs来添加我自己的操作员？

问题描述：

我使用的是rxjs (5.0+)，我想写一个我自己的Operator，其名称为append，用于Observable。现在我已经成功地创建了运算符并且它可以工作，但是如何告诉Typescript原始Observable支持我的新运算符？因为它抱怨编译错误象下面这样：如何扩展rxjs来添加我自己的操作员？

Property 'append' does not exist on type 'Observable'.

以下是我的源代码：

append.ts

Observable.prototype.append = function (value) { 
    return new Observable((observer) => { 
     const mapObserver = { 
      next: (x) => observer.next(x == null ? value : x + value), 
      error: (err) => observer.error(err), 
      complete:() => observer.complete() 
     }; 
     return this.subscribe(mapObserver); 
    }); 
};

test.ts

import './append'; 

export class Test { 
    init() { 
     Observable.from([1, 2]) 
      .append('a') // <--- Compile error! but in fact, it works. 
      .subscribe(function (x) { 
       console.log(x); // Works, output 1a and 2a 
      } 
     ); 
    } 
}

我知道我需要告诉Typescript关于我的新Operator，但我不知道该怎么做？我检查了rxjs的源代码，发现它包含以下代码src/add/operator/map.ts。我试图在我的append.ts中添加一些类似的代码，但我不知道包含Observable接口的模块名称是什么。（顺便说一句，我使用的打字稿2）

declare module '../../Observable' { 
    interface Observable<T> { 
    map: typeof map; 
    } 
}

答

在你的宣言合并指定的模块名称应该是一样的，当你输入Observable这是使用的模块名称。例如：

import { Observable } from 'rxjs/Observable'; 

... 

declare module 'rxjs/Observable' { 
    interface Observable<T> { 
    map: typeof map; 
    } 
}

如何扩展rxjs来添加我自己的操作员？

相关推荐