问题标签 [rxjs-observables]

我花了几个小时尝试不同的方法来让这个 Observable 在离子/角度工作。我尝试了不同的设置和接口来插入 Observable，它具有字符串属性。我尝试将 JSON 作为接口插入。我只需要对带有额外参数的 https 服务器进行 GET 操作。我不断收到错误消息，指出基本上返回的 http 无法正确输入到 getGP 中定义的 observable。错误是 删除订阅时，当 JSON 不用作接口时，我得到几乎相同的错误。一个简单的 GET/POST 很容易在 vanilla 中完成，而 Angular 让我发疯了。我还需要将响应保存在变量中并将数据注入另一个模块。我浏览了 rxjs 文档，但不知所措。帮助将不胜感激。我正在运行最新的 angular 和最新的 ionic 框架。

我有一个像这样响应的 api，我正在使用 rxjs observables

我需要将其转换为新的 json 格式，以便获得我想要的响应格式。

我已经尝试过 pipe(map()) 但我收到 Type ' 的错误Observable<void> ”不可分配给类型“ Observable<Error[]>”

我的模特

我的服务.ts

这是我到目前为止所尝试的，我删除了产生错误 My Component.ts 的代码

这是我需要的可观察输出

感谢那些愿意提供帮助的人

我一直在这里处理另一个问题，帮助者有点安静，我需要很快找到解决方案。浏览此处获取更多信息

我已经实现了新代码，发现数组正在向浏览器返回“false”：

我已经从 get 请求映射，然后尝试将佣金 $ 绑定到 click-cards.component.html。然后，这应该过滤掉所有重复的记录，并使用 lodash 将它们呈现为组。

编辑：根据反馈，但结果似乎仍然相同

click-cards.component.ts

我似乎无法找到让佣金 $ 绑定到 .html 文件的方法：

click-cards.html

有谁知道我在这里做错了什么？我通常不使用 Observables，所以我通常订阅服务 REST 方法并且它可以工作。所以我对这个过程有点陌生。

我有一个数据服务，它会在其他服务需要时定期触发 http 调用。现在，此服务异步工作，因此可能会在前一个尚未完成时请求数据服务触发 http 调用。

我想知道当我需要进行 http 呼叫时如何使用 rxjs 检查是否有正在进行的呼叫

数据服务：

服务一：

服务乙：

这种情况是当服务 B 调用 doB 而 syncA 已触发请求但尚未完成时。

我正在为我的一个 Angular 组件方法编写单元测试，该方法为一个属性分配来自服务调用的响应值并调用另一个方法。

我的服务带有响应数据，我在测试中使用订阅中的期望语句订阅它，但它一直将属性的值显示为空数组。我已经确认下面测试中的“响应”包含模拟数据，但无法让组件属性“resultSet”显示为分配的值。“toggleSearchForm()”方法的间谍似乎也从未被调用过。

被测试的方法： search.component.ts

失败的测试： search.component.spec.ts

服务存根： search-service.stub.ts

我希望 resultSet 包含存根响应和已调用的间谍，但测试失败并显示以下错误消息：

和

第一个返回一个对象数组。每个对象都有一个唯一的用户 ID，我需要它来调用第二个服务。

虽然它工作正常，但上面的代码有两个缺点。1. 它开始看起来像回调地狱。2.我必须自己处理每个订阅的处置。

I am using 3 endpoints for my application, 1 of the endpoints depends on other of the endpoint's response, which is a list, then I need to use each item of the list in order to use the other endpoint, let's call them epA, epB and epC, epA returns a list and then i use this list on epB, something like epA.Foreach( x => epB(x)) and I am trying to combine epB and epC into one combined list, since both share similar fields.

My problem is, I am too new using angular and observables, I don't know if there is a way to combine these epB and epC results (without mentioning that currently, I subscribe to the observables and assign its values to other objects I need)...If someone could give me a hand it would be greatly appreciated. Sorry if this is too messy, I have little experience posting here and coding in angular.

here's some code I currently have... it is a bit ugly but it does the job

code

I also tried forkjoin, but since epA returns a list, I don't know how to call each item inside of the forkjoin

我正在使用 Angular 和 WordPress REST API。一切都很顺利。但是我对以下代码的行为有点困惑。

上述功能驻留在服务中。当我尝试订阅返回的 observable 时，出现错误。但是下面的代码工作正常。

请澄清为什么上面的代码没有返回可观察的。提前致谢

我有一个BehaviorSubject. 我正在尝试将其转换Observable为 aConnectableObservable但我收到错误publishBehaviour不是函数。我究竟做错了什么？

this.questionsArray$.publishBehavior 不是函数类型错误：this.questionsArray$.publishBehavior 不是函数

代码片段是

我isUpdate在订阅中设置标志为真，我必须在延迟一段时间后将其设置回假，以便我可以显示一个快速弹出窗口

我尝试过使用.pipe(delay(2000)).subscribe但是整个回调被延迟了

预期结果：isUpdated 在一段时间内应该为假