rxJs publishLast沒有刷新消息

Question

我剛剛讀了http://blog.thoughtram.io/angular/2016/06/16/cold-vs-hot-observables.html，我試圖讓publishLast處理一些基本的觀察對象，我不能，有人可以解釋爲什麼嗎？

 let obs = Observable.create((observer: Observer<number>): void => { 
     observer.next(234); 
    }) 
     .publishLast() 
     .refCount(); 

    obs.subscribe((v: number) => console.log("1st subscriber: " + v)); 
    setTimeout(() => { 
     obs.subscribe((v: number) => console.log("2nd subscriber: " + v)); 
    }, 1100); 

Answer 1

我假設通過「沖洗」你的意思是你沒有收到你的訂閱塊中的任何事件。

的問題是，當它知道Observable不會排放任何更多的價值，它可以做到這一點的唯一方法是，如果你在Observer調用completepublishLast只能發出。

所以，你的代碼需要看起來像這樣：

let obs = Observable.create((observer: Observer<number>): void => { 
    observer.next(234); 
    observer.complete(); 
}) 
.publishLast() 
.refCount(); 

Answer 2

@ user2555964爲您的使用情況下，switchMap與distinctUntilChanged結合可能會提供一個解決方案。看看Angular的文檔，他們使用這兩個運營商來實現實時搜索框 https://angular.io/tutorial/toh-pt6#herosearchcomponent