RxJS Merge Observable in Callback

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を呼び出すと、その値がオブザーバに送信されます。

ほとんどの場合、既存の演算子はほとんどのユースケースに対してObservableを作成できるため、createを使用する必要はありません。それは、非常に具体的なニーズがある場合、Observableを作成できる低レベルのメカニズムです。

配列、配列のようなオブジェクト、イテレータ、Observableのようなオブジェクトと約束からObservablesを作成するObservable.fromもあります。