可观测需求平面映射（）在单（）

Question

每次我认为我理解了可观测物，但我不太理解可观测物。所以考虑一下我在Angular 4应用程序中使用的代码：

// this returns the url to our bitbucket server. the uriService returns
// an Observable<string>
return this.uriService.getBitBucketUrl(path)
  
  // I expect exactly one result, no more, no less, otherwise exception        
  .single() 

  // somehow I still need a flatMap here, to supply the url value into the nested observable
  .flatMap((url: string) => {
    
    // we now have the bitbucket url, use it to get json from it.
    return this.httpService.getJson(url)
      
     // map the result and flatten it to an array
     .flatMap((json: HttpResponse<any>): Array<any> => json.body.values)

     // map each value into a more managed model
     .map<any, BitbucketModel>((value: any) => {
        // create and return BitBucketModel here based on json
 })
});

我希望我对代码解释得足够好，所以它的本质是我不想在任何地方使用“订阅”。因为我使用异步管道，所以我希望可以一直观察到。但是，当我使用单（），然后我必须平面映射它，否则它给我一个错误，因为我不能返回可观察

如果我没有把我的问题说清楚，我很抱歉。我的场景是，我基本上需要一个配置设置，我的实际http请求基于该设置。所以我必须检索该设置，并根据该设置执行实际的http请求。

Answer 1

如果我理解正确的话，你是在问为什么platMap。让我试着解释一下。

map将输入同步转换为输出。所以它把每个项目转换成其他东西，用新项目替换旧项目。这个过程是同步的。

flatMap也会替换，但会异步替换。

flatMap获取一个项目，将其转换为可观测项目，并将新可观测蒸汽的输出置于原始项目的位置。

因此flatMap可用于这两个实例（可能是更多的应用程序）：

1. 如果输出是异步的（例如. url到超文本传输协议调用响应）
2. 如果输出是可观察的（ex.数组到独立元素）

前任：

...'string1'... 'string2'... => 
 ...Output(Observable created from string1)...
 ...Output(Observable created from string2)...

在您的情况下：

输入：字符串（url）

输出：来自异步http调用的json。

所以，你必须使用flatMap。它与单个代码无关

在您的示例中：

.flatMap((json: HttpResponse<any>): Array<any> => json.body.values)

这是一个同步转换。您正在获取一个对象并同步返回另一个对象。因此，它不必是平面图。你可以说

.map((json: HttpResponse<any>): Array<any> => json.body.values)

事实上，您的代码应该给出一个错误，因为flatMap期望Observable作为返回类型，但您正在返回一个对象。