操作符是函數(shù)，它基于當(dāng)前的 Observable 創(chuàng)建一個(gè)新的 Observable。這是一個(gè)無(wú)副作用的操作：前面的 Observable 保持不變。

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

看個(gè)例子：

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));}

調(diào)用我自定義的Operator multiplyByTen, 返回一個(gè)新的Observable實(shí)例：

在Observable的構(gòu)造函數(shù)里，將應(yīng)用程序傳入的subscribe方法傳入并維護(hù)到_subscribe方法里：

sink.add方法里調(diào)用應(yīng)用程序編寫的回調(diào)：

要獲取更多Jerry的原創(chuàng)文章，請(qǐng)關(guān)注公眾號(hào)"汪子熙":

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。