rxjs

0热度

1回答

我在我的角度应用程序中有这个问题，因为我正在缓存数据。使用onCreate（）函数添加内容后。我在successfull subscribe函数中调用getAll（）函数以获取新数据。但是，我仍然没有得到新的数据。我相信这是因为我服务中的缓存数据。我如何知道是否有新数据或者当有新数据时如何修复我的现有数据和刷新数据？服务 getAll() { if(!this.materials) {

0热度

7回答

Keyup event fire multipletime

目前，我正在开发Angular 4应用程序。在我的组件Html中，我有一个文本框。无论何时用户首先键入任何我想要进行API调用以获取某些数据。问题是如果用户键入'A'，那么它工作正常，并调用API。但是当用户输入“ABC”时，它会进行3次API调用。应该为每个字母进行API调用，而不是只进行一次调用。请提出任何解决方案。组件的HTML： <input id="inputbox" (keyup

0热度

1回答

角度延迟快速http请求

如何才能延迟http请求，只有当它在1秒内完成。第一种场景： - http请求在300ms内完成，然后等待1秒结束。第二种情况： - http请求在1秒内完成并且300ms，那么我们不会延迟。如何用observables来实现这个？

0热度

1回答

角4.2.4 +打字稿2.3.4 + RxJS 5.4.2： “第一个（）” 不是一个可观察到的已知

edit See Ikhtiyor's answer as it may fix the TypeScript related issue. My problem came from the fact I forgot to .subscribe and wrote the handler function in .first() directly. 所以，面对这个错误（！？！）： Propert

0热度

1回答

可观察 - 使动态请求的队列（角4）

我有一个关于观察到的问题。例如，我们的API，并发送reguest有： this.http.get('https://swapi.co/api/people/').subscribe(peoplesData => { let peoples = peoplesData.json(); let nextPage = peoples.next; // https://swapi.

1热度

1回答

将可观测数组Observable <boolean>与Observable <boolean[]>相结合 - 我正在做对吗？

比方说，我有可观察的可观察名单： const a = [Observable.of(false), Observable.of(false)]; const aSbj: Observable<Array<Observable<boolean>>> = new BehaviorSubject(a); 我想所有的观测量，结合内部成可观察布尔[]的。这是我的想法（使用打字稿）： const lis

1热度

1回答

做多回调减少nodejs性能？

我正在用mysql开发一个快速应用程序。我的节点版本是6.11.2。我的路由器文件是 const router = require("express").Router(); const project = require("../../modules/project/"); // individual project routes router.get("/", project.getA

3热度

4回答

如何使用debounceTime但在某段时间后仍然会触发该功能？

TLDR; 我想使用debounceTime来执行函数只有300毫秒已经过去，没有被调用。与此同时，我也希望能够每1分钟触发一次该功能。如果过程需要很长时间。否则，该功能只会在过程结束时触发。基本上，我们的系统有一个很长的过程，会向客户端发出大量的SignalR更新。当我在客户端接收到服务器命令时，我会向服务器发送2个额外的HTTP请求以获取一些信息。所以只要发送给我的服务器更新，它就会重新启动

0热度

1回答

RxJs：如何调用当两个可观察的订阅工作是从不同的API终点完成

我加载数据的方法，然后做设定，在每个数据同步的一些工作： // Invoked by user interaction loadData() { this.service1.getData().subscribe( data => { this.doSynchronousWork(data); this.data1 = data; }

1热度

1回答

拦截http响应时请求被发送两次

它发现当我们拦截HTTP响应并使用subscribe获取Observable响应中的值时，会触发2次请求。下面是代码 Intercerpting HTTP请求和响应通过延长它（http.service.ts） import { Injectable } from '@angular/core'; import { Http, XHRBackend, RequestOptions, Request