Observable内の他のObservableをどのように解決するのですか？ - rxjs

Question

私はObservableを持っていますが、私は別の観察可能なものを消費しますが、第2のObservableは解決できません。ここでは、コードは次のとおりです。

return Observable.fromPromise(axios(config)) 
     .map(res => { 
      return { 
       accessToken: res.data.access_token, 
       refreshToken: res.data.refresh_token     
      } 
     }) 
     .map(res => { 
      return { 
       me: getMe(res.accessToken), 
       accessToken: res.accessToken, 
       refreshToken: res.refreshToken     
      } 
     }) 

function getMe(accessToken) { 
    return Observable.fromPromise(axios.get({ 
     url: 'https://api.spotify.com/v1/me', 
    })); 
} 

getMe機能はObservableを返しますが、それが解決されることはありません。 flatMapとconcatを追加しようとしましたが、まだ解決されていません。解決するためにgetMeを取得するにはどうすればよいですか？

Answer 1

あなたは（また、未テスト）以下を試してみました：

function getMe(accessToken) { 
    return Rx.Observable.fromPromise(axios.get({ 
    url: 'https://api.spotify.com/v1/me', 
    })); 
}  

Rx.Observable.fromPromise(axios(config)) 
    .map((res) => { 
     return { 
      accessToken: res.data.access_token, 
      refreshToken: res.data.refresh_token     
     } 
    }) 
    .flatMap((res) => { 
     return getMe(res.accessToken).map((res2) => { 
      res.me = res2; 
      return res; 
     } 
    }) 
    .subscribe((data) => console.log(data)); 

、観察を返しflatMap上記の記事で述べたように。 mapを使用してresを2番目の約束から返された結果res2にマージします。

また、fromPromiseは低温で観測可能です。つまり、物事を開始するには購読が必要です。あなたのケースでは、私はあなたがすでにこのような何か持っていると推測：

someFunction =() => { 
    return Rx.Observable.fromPromise(axios(config)) 
    ... 
    ... 
} 

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

Answer 2

以下に見つけるサンプルコード（未テスト！）。いくつかの説明：mapオペレータが観測をフラット化していないため

• getMeによって返され、観察が平坦化されていません（「決意は」約束の世界に属しています）。 flatMapですが、source.flatMap(function(x){return observable})の形式で使用する必要があります。ここで返すものはPOJOで、Rx.Observableではありません。
• したがって、getMeをフラット化するには、flatMapを使用します。
• オブジェクト（res$）を発行したオブザーバブルに、不足しているフィールド（accessTokenとrefreshToken）を追加するにはwithLatestFromを使用します。

• res$に2回購読するので、shareを使用します。すべてのユーザに同じ値が表示されるようにします。

  var res$ = Observable 
      .fromPromise(axios(config)) 
      .map(function (res) { 
       return { 
       accessToken : res.data.access_token, 
       refreshToken : res.data.refresh_token 
       } 
      }) 
      .share(); 
  var getMe$ = res$.flatMap(function (res) {return getMe(res.accessToken)}); 
  var finalRes$ = getMe$.withLatestFrom(res$, function (getMe, res) { 
  return { 
      me   : getMe, 
      accessToken : res.accessToken, 
      refreshToken : res.refreshToken 
  } 
  }); 
  
  function getMe (accessToken) { 
      return Observable.fromPromise(axios.get({url : 'https://api.spotify.com/v1/me'})); 
  } 
  

Answer 3

@のuser3743222が指摘したように、ObservableはPromiseがないという意味ではないresolveを行います。 getMeメソッドの値をご希望の場合は、Observableを返信する必要があります。

return Observable.fromPromise(axios(config)) 
     .map(res => { 
      return { 
       accessToken: res.data.access_token, 
       refreshToken: res.data.refresh_token     
      } 
     }) 
     .flatMap(function(tokens) { 

      //FlatMap can implicitly accept a Promise return, so I showed that here 
      //for brevity 
      return axios.get({url : 'https://api.spotify.com/v1/me'}); 
     }, 

     //The second method gives you both the item passed into the first function 
     //paired with every item emitted from the returned Observable` 
     //i.e. axios.get(...) 
     function(tokens, response) { 
      return { 
      accessToken: tokens.accessToken, 
      refreshToken: tokens.accessToken, 
      //Here response is a value not an Observable 
      me: response 
      }; 
     });