Benutzerdefiniertes Observable erstellen

Question

es ist möglich (und korrekt), ein benutzerdefiniertes Observable zu erstellen? Zum Beispiel, wenn ich Daten in meinen Cache haben, würde ich benutzerdefinierte beobachtbaren erstellen möchten, bevor Sie eine HTTP-Anfrage machen:

meine Anfrage:

private device: Device; 
getDeviceById(deviceId): Observable<Device> { 
    if(this.device._id == deviceId) { 
     let myObservable = new Observable('with my device'); 
     return myObservable; 
    } else return this.http.get('/api/device/get/'+deviceId) 
       .map(res => res.json()) 
       .catch(this.handleError); 
} 

des Thank

Answer 1

Ja, können Sie ein Thema erstellen wie beobachtbar zu arbeiten, wie in Antwort can i emmit the event from parent to child erklärt, und benutze es, wenn du Daten in deinem Cache hast.

Answer 2

Sie können folgendes tun:

var button = document.querySelector('button'); 

var subscription = Rx.Observable.create(function(obs) { 
    button.onclick = function(event) { 
    obs.next(event); 
} 
.subscribe(function(value) { 
    console.log(value); 
},); 

in diesem Link, um mehr zu sehen:

getDeviceById(deviceId): Observable<Device> { 
if(this.authProvider == deviceId) { 
    return Observable.create(observer => { 
     observer.next("something"); 
     observer.complete(); 
    }); 
} else return this.http.get('/api/device/get/'+deviceId) 
      .map(res => res.json()) 
      .catch(this.handleError); 

Answer 3

Sie so etwas tun kann http://reactivex.io/documentation/operators/create.html