rxjs5

4熱度

1回答

的JSX我想裏面嵌入一個JSX組件cycle.js。我已經看到了使用JSX當其他組件內嵌入部件的documentation但不是一個例子，我不能在網上找到任何的例子。對於RxJs這樣的整個反應性事物我很新穎。在documentation的例子，他們似乎只是plonk的子組件到父組件（現在我可以看到他們把它傳遞到xs.combine（）函數）： const childVDom$ = labele

1熱度

1回答

Angular 2 RxJS過濾器到新的可觀察點

我對RxJS（使用5.1.1）非常陌生，並試圖在使用angular-redux/store的Angular 2應用程序中理解它。我已經建立了一個商店，並努力在我的應用程序中獲取我的狀態的不同部分。現在，我試圖讓已加載的屬性設置爲true AppParts：我的狀態： export interface IAppState extends IRootState{ theme: Them

0熱度

1回答

與RxJS

構建心跳服務，我想建立一個heatbeat服務，爲我angular2網站。遠程設備是網站的主機，客戶端應能夠檢測設備是否無法訪問/脫機。服務應定期輪詢（網絡服務器）遠程設備。我知道一個失敗的HTTP調用不能直接與整個設備的在線/離線狀態等同，但對於我的要求應該是足夠的。目前我使用以下可觀察其放置的角度服務的內部： public getStatus() { return this

4熱度

1回答

RxJS間隔無延遲

下面的代碼發出5000ms後int，然後又在每一個5000ms後： let evens = Observable.interval(5000) .map(i => { return i * 2; }); evens.subscribe((i) => { console.log(i); }); 是否有可能做到這一點，但馬上有第一個結果（0ms

1熱度

1回答

RxJS與Math.random（）

不能很好地玩我想學習Rxjs，我看到一些我沒想到的行爲。有問題的JavaScript代碼如下 function updateText(css_link, observable){ observable.subscribe(x => { const container = document.querySelector(css_link); container.textC

1熱度

2回答

。首先（）操作會影響其他訂閱

示例代碼： const test1$ = Rx.Observable.interval(1000) const test2$ = Rx.Observable.interval(1000) // This subscription need to get every value continuously const firstSub = test2$ .do(val => cons

1熱度

1回答

使用subscription.next（）是否爲反模式？

我有一個訂閱，我想用一箇中間件代碼來表示事件。所以我有一件事想要訂閱一個可觀察的事物，而另一件事情是不可觀察的。我想過使用科目爲這一點 - 這就是表裏如一成爲： const repeater = new Rx.Subject(); function subscribe(observer) { return repeater.subscribe(observer); } //

0熱度

1回答

Rxjs地圖子對象加父場

我有一個HTTP這種反應得到 { "parents": [{ "id": 1 , "children": [{ "name": "child1" } , { "name": "child2" }] }, { "id": 2 , "children": [{

1熱度

1回答

rxjs在錯誤後立即完成了observable而不是繼續

我試圖通過observable對一組內容進行流式處理，並在第一個錯誤後停止。將它看作一系列項目是簡單的，因爲它的行爲方式相同。我創建可觀察到的從項的陣列的每個項目映射到URL 調用URL作爲請求承諾執行一個catch（）返回一個observable.empty （）中的錯誤使用RxJS 5的事件： rx.Observable.from(array) .map(self.creat

0熱度

1回答

角及RxJS5 - 從http：插座

更新數據我有一種情況，我需要：獲取路線PARAMS 使用路線PARAMS調用http服務一旦HTTP響應，使用相同的路線PARAMS調用Socket服務每次插座響應，從HTTP服務更新數據理想我想保持這個我一個流。如果只有我可以使用CombineLatest？或涉及Scan運營商？ this.data$ = this.route.params .switchMap(par