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），有時數據被切斷流中的一半數據，我想再次加入他們的行列。我怎樣才能做到這一點？