角度/RxJS：同步可观测

Question

我有一个服务，有一个方法foo。在该方法中，我订阅了一个可观察的（超文本传输协议-客户端）。

foo () : boolean
{
  let ret : false;

  this.http.get ("/blabla").subscribe (
  (resp) =>
  {
    ret = true;
  }

  return ret;
);

我喜欢从foo返回一个布尔值，该值取决于get。这不起作用，因为http.get是asynchrouns-在http.get完成之前调用return。

我怎样才能使这个同步？

编辑

返回可观察的布尔值在这里不是一个选项。这是因为我处理get in foo的响应（此处未显示），但我也需要根据它的返回来执行foo。

编辑2

我用管子和水龙头扩展了我的样品。现在，我返回服务外部的http.get-observable，并用tap处理http.get-result。

foo () : Observable <any>
{
  return this.http.get ("/blabla").pipe (tap (x => handlehere ()));
}

就我看来，它只有一个丑陋之处。我有在foo内部和外部解析get结果的复杂性。我更喜欢foo之外的简单布尔值。

Answer 1

此方法只能异步运行，因此您没有太多选项。返回可观察的，订阅或返回promise。也许回报一个promise会满足你在理解方面的更多需求。

为您服务：foo方法：

async foo() {
   const result = await this.http.get("/blabla").toPromise();

   // do what you want with result 

   return result;
}

如何称呼它：

this.myService.foo().then( (result) => {
   // Do what you want with the result
});