rxjs5

0熱度

1回答

試圖構建一個可觀察的流，它將有條件地從兩個源中讀取。基於用戶選擇的文件流或當前會話的內存中的流。我有一個下拉，用戶可以選擇下列之一： Current //in-memory stream contains entries (error, warning, trace, debug) as they happen for the current session Error //error.log

4熱度

1回答

使用RxJS刷新/重新加載Hot Observable序列

我正在Angular 2中的Portal上工作。登錄時，我向服務器發出請求以獲取登錄的用戶配置文件。提取用戶配置文件的方法將返回一個在應用程序加載時在6個不同位置預訂的observable。如果我用了一個寒冷的觀察到的，這會導致6 API調用到服務器。所以我通過添加.publishLast（）。refCount（）來切換到一個熱門的observable。這導致了一個請求共享數據，因爲用戶的個人

1熱度

2回答

以Rx方式定期輪詢

我想輪詢一些布爾變量，直到它變爲false。我想編寫一個Observable，它發出單個值並完成，只有當特定變量爲false時。這裏是我特地用： let waitTask = Observable.interval(250) .do(() => console.log("DEBUG: Waiting for sync to finish.")) .takeWhile(()

0熱度

2回答

RxJs：對第一個和最後一個用戶採取可觀察行動

在我的Angular 2.x應用程序中，我有一個組件，它訂閱了服務公開的observable。可觀察數據服務目前是通過輪詢HTTP請求來實現的，但是這將改變爲被動WS實現。我想保留組件的輪詢，所以問題是：如果我有訂閱者，我如何採取行動，例如通過setInterval進行HTTP輪詢？而且，如何在沒有更多用戶時採取行動，如clearInterval？視圖是異步更新： <div *ngFor="le

2熱度

2回答

角2 - 屬性'skipLast'不存在類型'Observable <number>'

我在角2組件中使用行爲主題，我想第二個發出的值在最後一個之前，RxJs document說我應該對我的skipLast方法流忽略他們，但那個說，雖然使用它，我得到一個錯誤：2.3.1 Rx.js版本：5.0.3 住宅「skipLast」不上鍵入「可觀測」角版本存在這個是我的代碼： import 'rxjs' import { BehaviorSubject } from 'rxjs/Behav

0熱度

1回答

類似的可觀察運算符Promise.resolve（）

是否有像Promise.resolve()這樣的Rx運算符，其中可以將可觀察值或普通值解析爲普通值？例如，我可以這樣做： Promise.resolve(3) .then(function(val){ console.log('val => ',val); }); ，當然還有，Promise.resolve（）將接受一個承諾以及但是，我很難找到一個類似的Rx運營商，類似：

0熱度

1回答

高級例子

我也有類似的數據結構，以這樣的： let userInfo = [ { id: 'id1', users: [ { name: 'userName1', job: 'userJob', }, { name: 'userName2', job: 'userJob', }

0熱度

1回答

爲什麼結果不被分享？

我有下面的代碼片段： const source$ = Rx.Observable.from([1,2,3,4]) .filter(x => x % 2) .map(x => x * x) .share(); source$.subscribe(x => console.log(`Stream 1 ${x}`)); source$.subscribe(x => c

3熱度

1回答

在Angular2中共享組件/組播之間的可觀察性

學習observable和Angular2。我想找出在多個Angular2組件之間共享可觀測數據的最佳實踐。由於可觀察的默認值不是多播。因此，我的應用的不同部分中的每個訂閱都會打開一個新的流（再次調用我的API服務器！）。另外，我需要分享價值並獲得該可觀察值的最新價值。我聽到人們使用行爲主題。但是這真是令人困惑，我找不到一個很好的例子。下面是我如何處理這在我authService： userInf

26熱度

1回答

Rxjs：Observable.combineLatest vs Observable.forkJoin

只是想知道Observable.combineLatest和Observable.forkJoin之間有什麼不同？據我所知，唯一的區別是forkJoin期望Observables完成，而combineLatest返回最新值。