操作符是函數，它基于當前的 Observable 創建一個新的 Observable。這是一個無副作用的操作：前面的 Observable 保持不變。

操作符本質上是一個純函數 (pure function)，它接收一個 Observable 作為輸入，并生成一個新的 Observable 作為輸出。

看個例子：

ngOnInit(): void {// input has type observablefunction multiplyByTen(input) {return new Observable(function subscribe22anyname(observer) {input.subscribe({next: (v) => observer.next(10 * v),error: (err) => observer.error(err),complete: () => observer.complete()});});}const inpute = from([1, 2, 3, 4]);const output = multiplyByTen(inpute);output.subscribe(x => console.log(x));}

調用我自定義的Operator multiplyByTen, 返回一個新的Observable實例：

在Observable的構造函數里，將應用程序傳入的subscribe方法傳入并維護到_subscribe方法里：

sink.add方法里調用應用程序編寫的回調：

要獲取更多Jerry的原創文章，請關注公眾號"汪子熙":

總結

以上是生活随笔為你收集整理的Angular rxjs里自定义operator的使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。