rxjs6 相关问题

RxJS6是Reactive Extensions for JavaScript的第6版,在websocket,测试和错误修复方面添加了一些更改。

TypeError:_rxjs.Observable.fromPromise不是函数

我在React Native中使用rxjs。我叫Observable.fromPromise(storage.load({key:key}))。map(()=> value);显示错误。我的rxjs版本:“ rxjs”:“ ^ 6.5.3”,“ rxjs-compat”:“ ^ 6.5.3”,我有三个...

回答 1 投票 0

如何在Observable.merge中停止观察者?

我有一个创建计时器的方法:create(options:any){返回timer(0,1000).pipe(map(()=> {return options;}),takeWhile(()=> new Date()

回答 1 投票 0

如何创建一些计时器并显示它们的结果?

我使用RXJS创建了计时器:let timer1value = null;让timeFinish = 30;让finishDate = new Date(); return timer(1000).pipe(takeWhile(()=> new Date()

回答 2 投票 0

在观察到的内容已订阅时轻按

是否有办法向已订阅的可观察对象添加更多操作?我尝试了下面的代码,该代码不起作用,因为未执行订阅部分后的另一次点击(代码为...

回答 1 投票 0

RXJS-等待两个可观察值都完成

我是RXJS的新手,我正在编写一个验证功能,其中可能会弹出2个模态(一个接一个),用户必须确认它们可以破坏验证规则。我是...

回答 1 投票 0

多个订阅嵌套到一个订阅中

我发现尝试设置一个非常简单的rxjs订阅流程感到困惑。将多个不相关的订阅嵌套到另一个订阅中。我正在从事有角度的申请,我需要一个主题是...

回答 2 投票 -1

如何通过正确的打字稿推断在RxJS中延迟跳过错误?

我只想记录一个错误并跳过此步骤,但是会延迟并且具有正确的打字稿推断。 const fetch =()=> Math.random()> 0.5吗? Promise.resolve(“ Success”):Promise.reject(“ ...

回答 1 投票 0

rxjs自定义重试,带有自动递增延迟的策略无法正常工作

我正在尝试创建一个自定义的retryWhen策略,该策略尝试在N次延迟之间重试N次并随后失败。在某种程度上,learnerxjs.io示例正是我想要的。 ...

回答 1 投票 0

如何使用RxJS发出多个HTTP请求,并将响应合并到一个有效负载中,并将其映射到另一个动作?

按照标题,我一直试图找出一种从动作有效负载进行多个HTTP调用,并将所有结果基本上合并到单个数组中,然后将结果映射到另一个...

回答 2 投票 0

我如何使用RXjs缓存请求?

情况如下:有一个文本。每个文本都会更改,我会提交一个请求。响应文本分为多个部分。然后,我将每个部分再次发送到服务器。示例:请求-...

回答 1 投票 0

任何想法,为什么我的RxJS api调用都会捕获每个击键而不是等待?

我正在尝试使用Angular 7.3.1和RxJS 6.4对RxJS进行前瞻性。当我键入内容时,将发送每个击键,而不是等待一段时间以捕获所有击键。 my.service.ts ...

回答 1 投票 2

TypeScript代码正在执行,但不应该

我正在使用TypeScript和Rxjs。我正在使用Rxjs将数据发送到服务器。我还实现了自定义拦截器。拦截器返回一个type:0事件,以及服务器的响应...

回答 2 投票 1

在Angular的后端响应中创建隐藏的自定义错误

我正在编写Angular8应用程序,其中服务器始终给出200s系列答案。来自服务器端的所有错误都包装在Response对象中,因此,我必须从...

回答 1 投票 -1

Rxjs-比较map()的两个不同情况

比较此返回this.httpClient.get('https://geocode.arcgis.com/arcgis/rest/services/World/GeocodeServer/suggest',{params:data})。pipe(map((x:any )=> x.suggestions.map((y)=> ...

回答 1 投票 0

使用多个异步调用中的值,然后执行计算以推送值

我正在进行4个异步api调用floor.entities.forEach(elementId => {let objTemp:any = {}; objTemp.main = elementId.name let currentTempForZone; //这是第一个异步函数。...

回答 1 投票 0

在获得api调用后的响应之后,抛出错误=> .pipe不是函数

我正在进行api调用,并期望可以将其传递给第二个api调用,但出现错误ERROR TypeError:this.helperService.getPointIdbybys(...)[0] .pipe不是。 ..

回答 1 投票 -2

RXJS如何延迟每个可观察的(http请求)并组合所有请求的输出

我在一个可观察的范围内设置HTTP请求之间的间隔有问题。事情是-我希望每个http请求之间都有延迟,等待所有请求完成,然后执行...

回答 4 投票 1

如何等待从api加载数据,然后在UI中执行其他操作?

我有一个从api获取用户列表并填充列表组件的方法。现在,我想做的是一旦从api加载列表后,突出显示列表的第一个元素。我有...

回答 2 投票 0

如何从可观测的角7返回对象

我已经有了角7和[email protected]一个应用程序。我想从我的可观察对象中获取价值,我不知道为什么它不返回。还有就是我的示例代码:HTTPS://stackblitz.com/edit / ...

回答 5 投票 -1

HttpClient的GET变换对象的响应阵列

以下是我的模型。导出接口跟踪线索{logAction:字符串,targetEmpId:字符串,createdDate:日期}下面的代码从一个GET调用检索数据并将其转换。上市 ...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.