摘要:原文什么是是一個對象,表示一種可被處置的資源,通常指代一個流的執行過程。在之前版本中的,被稱為可被處置的。本質是一個含有方法,用來釋放資源或者取消流執行的對象。
原文: http://reactivex.io/rxjs/manu...
什么是Subscription? Subscription是一個對象,表示一種可被處置的資源,通常指代一個Observable流的執行過程。
Subscription有一個重要的方法unsubscribe(),不需要參數,僅僅用來釋放掉subscription實例所持有的的資源。
在之前版本中的RxJS,Subscription被稱為“可被處置的”。
var observable = Rx.Observable.interval(1000); var subscription = observable.subscribe(x => console.log(x)); // Later: // This cancels the ongoing Observable execution which // was started by calling subscribe with an Observer. subscription.unsubscribe();
Subscription本質是一個含有unsubscribe()方法,用來釋放資源或者取消Observable流執行的對象。
多個Subscription可以被組合在一起,從而使調用其中一個Subscription的unsubscribe()方法能夠讓所有的Subscription都取消流的執行。要做到這一點,可以將一個subscription實例“添加”到另一個中去:
var observable1 = Rx.Observable.interval(400); var observable2 = Rx.Observable.interval(300); var subscription = observable1.subscribe(x => console.log("first: " + x)); var childSubscription = observable2.subscribe(x => console.log("second: " + x)); subscription.add(childSubscription); setTimeout(() => { // Unsubscribes BOTH subscription and childSubscription subscription.unsubscribe(); }, 1000);
執行一下,我們可以看到輸出是這樣的:
second: 0 first: 0 second: 1 first: 1 second: 2
Subscription也有一個名為remove(otherSubscription)的方法,用來撤銷已經添加到其中的其他Subscription。
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://m.specialneedsforspecialkids.com/yun/83626.html
摘要:通過執行和可以向訂閱者推送不同的通知。之后,執行過程可能被處理掉。當調用并得到觀察者時,在中傳入的函數將會被執行。每次執行都會觸發一個單獨針對當前的運行邏輯。通知不發出任何值,表示流的結束。 原文:http://reactivex.io/rxjs/manu... Rx.Observalbe.create()或者創建操作符,可以 創建(created) Observable流。Obser...
摘要:舉例來說,每年都有生日是一道數據流,但是一個人的年齡卻是一個流。運行結果顯示,第二個在訂閱之后,獲得了數據流中最后毫秒事件內產生的和三個值。 原文:http://reactivex.io/rxjs/manu... Subject是什么? RxJS的Subject是Observable的一個特殊類型,他可以將流中的值廣播給眾多觀察者(Observer)。一般的Observalbe流是單一...
摘要:原文是一個使用可觀察量隊列解決異步編程和基于事件編程的庫。提供了幾個管理異步事件的核心概念可觀察量,代表了一個由未來獲取到的值或事件組成的集合。相當于事件觸發器,是向多個廣播事件或推送值的唯一方法。 原文:http://reactivex.io/rxjs/manu... RxJS 是一個使用可觀察量(observable)隊列解決異步編程和基于事件編程的js庫。他提供了一個核心的類型O...
摘要:到底是什么先上代碼輸出這里可以把想象成一個函數,這意味著你每次調用都會導致傳入里的回調函數重新執行一次調用的方式為相當于。接收函數返回值的方式也從改為通過傳入回調函數的方式獲取。具體看代碼運行結果如上的第一個回調函數里的結構是推薦的結構。 通俗的方式理解Rx.js 序言 今早看民工叔的文章的時候, 發現對Rxjs所知甚少, 于是去官方看了下教程, 整理出一些東西, 寫成此文。Rxjs據...
閱讀 2027·2021-11-15 11:38
閱讀 2058·2019-08-30 15:55
閱讀 2193·2019-08-30 15:52
閱讀 3177·2019-08-30 14:01
閱讀 2694·2019-08-30 12:47
閱讀 1161·2019-08-29 13:17
閱讀 1074·2019-08-26 13:55
閱讀 2641·2019-08-26 13:46