RxJS回調

Question

合併可觀察我需要做一個函數返回一個可觀察到的一點幫助。我有一個函數（讓我們稱之爲mainFunction），調用異步函數（姑且稱之爲getAsyncWithCallback）和執行的回調。回調的一部分是一個異步調用返回一個可觀察到的（姑且稱之爲getData）。

getAsyncWithCallback是一個庫的一部分，我不能改變它。

這是我有：

mainFunction(){ 
    getAsyncWithCallback(() => { 
     let myObservable = getData(); 
    }); 
} 

這就是我想做的事：

mainFunction().subscribe((data) => { 
    // data is the data from getData() 
}); 

什麼是實現這一目標的最佳途徑，而鏈的錯誤和完成形成內？

Answer 1

我的解決方案：

mainFunction(): Observable<any> { 

    return Rx.Observable.create(observer => { 
     getAsyncWithCallback((): void => { 
      getData().subscribe(observer); 
     }) 
    }) 
} 

mainFunction().subscribe((data) => { 
    console.log(data); 
})); 

Answer 2

你會想從mainFunction返回可觀察到的。

如果的getData返回一些其他類型的對象不是可觀察，你會構建自己的可觀測與Observable.create：

function mainFunction() { 
    return Observable.create((obs) => { 
    getAsyncWithCallback(() => { 
     getData() 
     .subscribe((data) => { obs.next(data); }) 
     .catch((err) => { obs.error(err) }); 
    }); 
    }); 
} 

mainFunction().subscribe(data => console.log(data)); 

從文檔：

創建onSubscription功能轉換爲一個實際的Observable。每當有人訂閱該Observable時，該函數將作爲第一個且唯一的參數與Observer實例一起調用。

使用值調用next會將該值發送給觀察者。

你最不應該需要使用創建的時代，因爲現有的運營商允許你創建一個可觀察到的大部分的使用情況。這就是說，如果你有非常特殊的需求，create是一個低級機制，允許你創建任何Observable。

還有Observable.from它將從數組，類似數組的對象，迭代器，Observable-like對象和Promise中創建Observables。