創建自定義Observable

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

感謝的

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