rxjs

0热度

1回答

rxjs首先完成整个流式链接

我有一个角度为5的应用程序，rxjs WebsocketSubject发送jsonrpc消息。 这是我sendRequest将功能 sendRequest(request: Request): Promise<Response> { console.log(request); this.socket.next(JSON.stringify(request));

rxjs json-rpc 2017-12-03

---

1热度

1回答

Rxjs运营商在迁移到Angular 5后捆绑了两次

最近，我的团队将Angular 4项目迁移到了Angular 5.同样在此迁移中，我们开始使用Angular cli。一切正常，项目正在运行，我们终于设法减少了包的大小（aot，树震动，构建优化器等）。 唯一的问题是，在最终捆绑包中，rxjs似乎包含两次（bundle analyzer screenshot）。 当然，我们改变了所有可见进口 import {Observable} from 'rx

angular rxjs angular-cli 2017-12-03

---

1热度

1回答

订阅在当时发出一个项目而不是在Rxjs中的列表

我目前正在努力弄清楚Angular 4应用程序中Rxjs的行为。 我的代码是： this.server.get("incidents") //http get resource .flatMap((res) => res.value) //the incident array is in a property called value of the json returned .map((in

angular rxjs observable 2017-12-03

---

1热度

1回答

Angular：刷新令牌只有一次

我正在使用JWT刷新令牌策略作为身份验证，并且在我的Angular客户端中有一个拦截器将令牌作为标头发送。 我在发送之前检查过期时间，并在需要时使用我的refreshToken刷新令牌。 问题是发送2个（或更多）请求时，都尝试刷新令牌。我需要一个函数，它发送刷新令牌的req，并且一次调用多次，只向服务器发送1个http req以进行刷新，并将新的更新的令牌返回给所有调用它的人。 这是我的拦截器：

angular rxjs observable 2017-12-18

---

4热度

2回答

Angular 4中的WebSocket

我正在用Angular 4和websocket创建聊天应用程序。对于这一点，我已经按照这个Angular websocket tutorial 这里是WebsocketService源代码： import { Injectable } from '@angular/core'; import * as Rx from 'rxjs/Rx'; @Injectable() export clas

angular typescript websocket rxjs observable 2017-12-18

---

0热度

1回答

在2个不同模块的2个组件之间共享数据Angular 4

在我的应用程序中有2个模块，即AppModule和UserModule。 但我在共享AppComponent和LoginComponent（它是UserModule的一部分）之间的数据共享时遇到问题。 这里是app.component.html <ul class="nav navbar-nav lg-nav visible-lg visible-md"> <li><a routerL

javascript angular typescript rxjs 2017-12-18

---

4热度

1回答

RxJS：如何将多个嵌套的观测数据与缓冲区结合使用

警告：RxJS newb在这里。 这里是我的挑战： 当onUnlink$观察到发射... 立即开始从onAdd$观察到的捕获值，最多1秒（我会打电话给此分区onAddBuffer$） 。 查询数据库（创建doc$观察到的）来获取我们将使用来匹配的onAdd$值之一 如果从onAddBuffer$观察到的一个值的doc$值相匹配的模式，不排放 如果没有值从onAddBuffer$观察到的doc$值匹

javascript rxjs observable rename rxjs5 2017-12-18

---

0热度

2回答

rxjs中是否有逻辑或类型的运算符？

我有一个角度服务，我想暴露一个observable，它充当逻辑“或”的类。假设我有多个源序列可以给出on和off的值。我需要输出true任何时候任何东西都是on，并且当所有值为off时返回false。 例子： const replaceInput = input => input === 'on' ? 'off' : 'on'; const getSource = (name) => Obser

angular rxjs logical-or 2017-12-27

---

0热度

1回答

角度服务中RxJS主题的​​上下文处理

我有一个热门的RxJS Observable，我想根据应用程序的上下文采用不同的方式进行响应。该主题发出基于由指令拦截一些全球性行动的新事件，但后来我想 若一个子组件订阅的主题，那么孩子应该处理该事件 否则，使用全局处理程序 我可以从主题获取订阅者的数量，然后告诉全局处理程序忽略是否有多个订阅者，但它不是API的一部分，所以它看起来可能不是正确的方式来处理它。那么做这件事的正确方法是什么？ 此外，

javascript angular typescript rxjs 2017-12-27

---

1热度

1回答

模拟Angular 2中的长响应

为了教育目的，我需要模拟Angular 2中服务器的长响应。我有代码 getTasks() : Observable<Task[]> { return this.http.get('data/tasks.json').map(response => { return response.json(); }); } // using getTasks().sub

angular typescript rxjs observable 2017-12-27

---