Создать пользовательский наблюдаемый

Question

можно (и правильно) создать пользовательский наблюдаемый? Например, если у меня есть данные в моем кэше, я хотел бы создать пользовательские наблюдаемым, прежде чем сделать запрос HTTP:

мой запрос:

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); 
} 

Thank в

Answer 1

Да, вы можете создать один предмет работать как наблюдаемый, как описано в ответе can i emmit the event from parent to child, и использовать его, когда у вас есть данные в вашем кеше.

Answer 2

Вы можете сделать следующее:

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

вы можете сделать что-то вроде этого:

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); 
},); 

больше в этой ссылке: http://reactivex.io/documentation/operators/create.html