如何用Observable編寫函數？

Question

我想創建一個返回函數的Observable .The描述如下功能：

1. 的功能應該是delayedAlert(message:string, time:number)返回一個Observable。

2. 該函數應包含內部delayedAlertsetTimeout函數設定「time」值後打印message。

例：

delayedAlert(message, time){ 
return new Observable//how to implement setTimeout function here? 

Answer 1

使用Observable.create創建觀察到的，並在第一個回調，寫來填充觀察到的，而你的情況是setTimeout邏輯。

function delayedAlert(msg, time) { 
    return Observable.create(
    observer => setTimeout(() => observer.onNext(msg), time)); 
} 

然後使用它：

delayedAlert("Hi, Sally", 1000).subscribe(msg => alert(msg)); 

但是，如果使用的是可觀察，你並不需要使用setTimeout;使用delay而是適用於of，這就造成個別值（一個或多個）可觀察到的：

function delayedAlert(msg, time) { 
    return Observable.of(msg).delay(time); 
} 

因爲它是那麼容易就這樣寫，你可能並不需要delayedAlert功能都：

const observable = Observable.of("Hi, Sally").delay(1000); 

observable.subscribe(msg => alert(msg));