rxjs5

0熱度

1回答

我有一個角2路由器後衛其canActivate方法被定義如下： canActivate() { return this.sessionSigninService.isAuthenticated() .filter(isAuthenticated => isAuthenticated !== null) .map(isAuthenticated => {

2熱度

1回答

當流退訂

我有我分享如下所示的RxJS觀察到的流觀察： var sub = Observable.create(obs => { // logic here return() => { // call rest service to notify server }; }) .publish() .refCount(); 當最後一個用戶取消訂閱，我需要做一

1熱度

1回答

Angular2 Observable與RxJS沒有錯誤，但沒有發生事件

我正在建立一個簡單的輸入類型的文本，其中一個Observable對象鏈接到它的關鍵事件。我正在使用Angular2 final（「@ angular/core」：「〜2.1.1」和「rxjs」：「5.0.2」）。這裏是我的app.component.ts： import {Component} from '@angular/core'; import {Observable} from 'r

0熱度

1回答

ReplaySubject.next（value）違反了redux store的不可變狀態原理嗎？

我有一個Angular2應用程序，從要求身份驗證的源獲取的數據，所以該應用部件init事件發起身份驗證令牌獲取這樣的： import { Component, OnInit } from '@angular/core'; import { NgRedux } from '@angular-redux/store'; import { rootReducer } from './app.redu

4熱度

1回答

如何在輪詢時使用RXJS HTTP處理Angular2中的連接丟失

我有以下代碼（簡化了此帖） - 假定初始調用onStart()。運行這個工作正常。如果我失去了互聯網連接，我得到net::ERR_INTERNET_DISCONNECTED錯誤（按預期）但輪詢停止。顯然，我沒有處理任何錯誤，因爲這是我卡住的地方。我不清楚我在哪裏處理這些錯誤以及如何處理？我需要再次撥打startPolling()嗎？即使沒有互聯網連接，我也需要輪詢才能繼續，以便重新連接數據得

1熱度

1回答

RxJS 5 WebSocket的陣列信息

我通過這一格式的WebSocket連接接收消息： [ { //msg 1 }, { //msg 2 }, .... ] 基於一些例子我在這裏發現在網絡上是我的代碼： public messages: Subject<Message> = new Subject<Message>(); //...

1熱度

1回答

如何從一個XML文件

示例文件流持續更新： <currencies><usd_gbp>0.80</usd_gbp><usd_eur>0.94<usd_eur></currencies> 我有一個包含貨幣匯率的XML文件http://somesite.com/curency.xml。該文件定期更新。我希望一個流能夠在更新發生時實時發佈更改。你將如何創建一個實時發佈更新的rx.js可觀察流？到目前爲止，我一直在看這個

2熱度

1回答

對象vs AnonymousSubject

Subject和AnonymousSubject in RxJS 5有什麼區別？我搜索了互聯網，但沒有找到任何有關AnonymousSubject的信息。我發現一個例子，網絡 Subject.create(observer, observable); 展望rxjs源代碼上我看到這個創建和AnonymousSubject。你還可以拿出一個很好用的例子AnonymousSubject？

8熱度

3回答

rxjs 5發佈重播RefCount

我不知道如何publishReplay().refCount()的作品。例如（https://jsfiddle.net/7o3a45L1/）： var source = Rx.Observable.create(observer => { console.log("call"); // expensive http request observer.next(5);

0熱度

1回答

angular2，RxJs過濾器可觀察結果？

我打電話給一個服務並返回一個json對象。我想過濾結果，但似乎無法讓它工作。該請求工作正常，我傳遞一個關鍵字使用過濾器功能。我試圖控制檯登錄它，但它返回一個空的數組。提前致謝。 let keywords = 'defunkt'; this.http.get('https://api.github.com/users') .map((res: Response) => res.jso