當流退訂

Question

我有我分享如下所示的RxJS觀察到的流觀察：

var sub = Observable.create(obs => { 
    // logic here 

    return() => { 
     // call rest service to notify server 
    }; 
}) 
.publish() 
.refCount(); 

當最後一個用戶取消訂閱，我需要做一個REST請求。明顯的選擇是將該調用添加到return清理函數中 - 但是隨後您已經打破了任何可觀察的序列，並且任何錯誤等都不易處理。

我只能使用Subject，在清理函數中將一個值推送到它上面，並在其他地方用REST調用掛住它。

理想情況下我會做這樣的事情串聯到處置流與我的REST調用（concat明顯，因爲它是沒有完成將無法正常工作）。

有沒有人有最清潔的方式處理這個問題的任何建議？上述所有選項似乎有點笨重，我覺得我錯過了一些東西。

Answer 1

你可以在你的流中實現一個finally(...)，進行清理。 流確定後（錯誤或完成），finally自動執行。

注意：當您手動取消，並在您的流不叫complete這將不工作。