rxjs

2热度

2回答

我有多个父对象，每个都有多个子对象，每个子对象都有多个链接。我想检查所有的儿童链接，删除没有实时链接的儿童，并删除所有孩子已被删除的父母。我想做了解如何编写角4使用的Rx下面的代码： parents.reduce((updatedParents, parent) => { parent.children = parent.children.reduce((updatedChildern, ch

0热度

1回答

rxjs树搜索

我是rxjs的新手，需要找到一种算法来通过树中的id查找节点。这是我的最好的方法（可作为公共要点在gistrun）： const value= "c.1.3"; const tree= [ { "id": "c.1", "children": [ { "id": "c.1.1" }, { "id": "c.

0热度

1回答

Observable不被称为Subject.next（）

价值变化我试图建立一个自动完成，我使用Observable和主题。但是，只要Subject对象的值发生更改，服务方法就不会被调用。以下是我定义主题的组件代码。 detailsPersist.component.ts import { Component, OnInit } from "@angular/core"; import { Subject } from 'rxjs/Subject';

0热度

1回答

NgRx无法从商店中选择

我正在做一个非常简单的NgRx实现，现在只是做一个组件的get。数据根据Redux Devtool在有效负载中传递，但我似乎无法通过异步管道访问它。 Devtool： ---更新---- 的问题是，当我在TS文件访问该片，我得到的错误 ''network''类型的参数不能分配给类型为的参数''start''。 TS文件 constructor(private store: Store<fromA

0热度

2回答

未处理的Promise拒绝：Rx_1.Subject不是构造函数;区域：;任务：Promise.then;值：TypeError：Rx_1.Subject不是构造函数

我有一个angular2应用程序，它使用systemjs来映射/加载。导入该项目的rxjs，并引用它是好的，但是当代码部署，它未能建立与消息的主题变量： "Unhandled Promise rejection: Rx_1.Subject is not a constructor ; Zone: ; Task: Promise.then ; Value: TypeError: Rx_1.Subj

0热度

1回答

RxJS：JSON移动对象属性下面

的水平我有以下JSON：我apps是对象的数组。 apps数组在另一个包装它的json对象内。我创建了下面的方法返回应用程序列表： return this.http.get(`analytics`) .map((data: any) => { return data.apps; }); 现在，你可以在截图中看到，有一个bandwidth对象与total属性。我需要的total财产

0热度

1回答

RXJS获取ReplaySubject的当前值

我想从登录时的ReplySubject中获取当前值。在当前流程中订阅时，将返回先前的值而不是当前值。所以收到的东西是以前的东西在登录，而不是目前的东西。有没有办法在ReplaySubject上获取订阅中的observable的当前值，而不必求助于BehaviorSubject？ stuff.service.ts： private _stuffSubject = new ReplaySubject<

0热度

1回答

Rxjs从最初的源处理数据几次

我有一个Observable，我想从同一个源处理数据两次而不修改下一个数据。我的意思是如果我使用两次.map（）第一个修改数据，第二个获取修改后的数据。我不想那样。对不起，当然我可以在StackOverflow中找到答案，但我没有找到它与我的话，我不明白从Rxjs文档模式。 UPDATE this.anObservable .map((data) => { // Here

0热度

1回答

如何批量添加到由rxjs observables返回的数组/列表中？

有可观察的，返回的东西阵列/列表：可观察而且我有一个用例在哪里是这个观察到的下游消费有更多的项目加入到这个名单相当昂贵的事。所以我想减慢对这个列表的添加量，但是没有任何松动。类似于一个操作符，它使用此可观察值并返回具有相同签名的另一个可观察值，但是无论何时新列表被推入并且其上的项目多于上次，则一次只添加一个或几个。因此，如果上次推送是一个包含3个项目的列表，并且下一个推送项目是6个项目，并且

1热度

3回答

如何加入两个半在RxJs

我有这样 ---ab---ab---a---ba---bab---ab---ab---ab---> 流，我想这一点。 ---ab---ab------ab----ab-ab-ab---ab---ab---> 的一点是，我有开始和结束（JSON），有时数据被切断流中的一半数据，我想再次加入他们的行列。我怎样才能做到这一点？