源代碼：

import { of } from 'rxjs'; import { Injectable } from '@angular/core'; import { map } from 'rxjs/operators'; import { tap } from 'rxjs/operators';@Injectable() export class JerrySandBoxService{name = 'Jerry';print(){const observable = of(1, 2, 3);const newObservable = observable.pipe(tap(num => console.log(num)),map(num => 'hello world: ' + num));newObservable.subscribe(data => console.log(data));} }

執行pipe之前先執行map函數：

map返回一個新的函數：

然后執行pipe函數：…operations變長參數，包含tap和map兩個操作。

pipeFromArray的實現借助了JavaScript的closure閉包：

到目前為止，我們傳入的tap和map里的箭頭函數都未執行，直到subscribe方法的調用：

此時對于數組里的1，2，3，先執行管道里的tap和map操作，再把map操作的輸出，作為輸入去執行subscribe里指定的回調：

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

總結

以上是生活随笔為你收集整理的通过一个最简单的例子，理解Angular rxjs里的Observable对象的pipe方法的全部內容，希望文章能夠幫你解決所遇到的問題。

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