Wie schreibt man eine Funktion mit einem Observable?

Question

Ich möchte eine Funktion erstellen, liefert eine Observable .Die Beschreibung der Funktion ist wie folgt:

1. Die Funktion delayedAlert(message:string, time:number) sein sollte, dass ein Observable zurückgibt.

2. sollte die Funktion setTimeout Funktion innerhalb delayedAlert enthalten, die message nach dem Satz druckt ‚time‘ Wert.

Ex:

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

Answer 1

Verwenden Observable.create die beobachtbare, und in dem ersten Rückruf, schreiben die Logik zu erstellen, die beobachtbar zu füllen, die in Ihrem Fall ist die setTimeout.

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

Dann, es zu benutzen:

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

Wenn Sie jedoch Observablen verwenden, brauchen Sie nicht setTimeout zu verwenden; verwenden delay stattdessen angewendet of, die eine beobachtbare von Einzelwert schafft (e):

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

Da es so einfach ist es auf diese Weise zu schreiben, werden Sie wahrscheinlich nicht brauchen, um alle delayedAlert Funktion:

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

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