rxjs5

1熱度

1回答

我想知道爲什麼在示例波紋管中的onComplete回調從未得到執行。下一個回調按預期執行。如果我在foo創建的觀察值中拋出一個錯誤，則錯誤回調也會被執行。只有完整的回調沒有得到執行。 JSBin：http://jsbin.com/punoridajo/edit?html,js,console,output let button = document.getElementById('click-me

2熱度

2回答

「RxJS找不到任何全球範圍內的」

我的角4應用程序通過角CLI建立停止工作，顯然是出於藍： ng --version` 導致以下錯誤： RxJS could not find any global context (window, self, global) Error: RxJS could not find any global context (window, self, global) at /home/j

1熱度

1回答

如何創建一個從節點請求可觀察的RxJs

目前可以明確地創建一個可觀察到如下： const Rx = require("rxjs"); const request = require("request"); return Rx.Observable.create(function (observer) { request(options, function (error, response, body) {

1熱度

2回答

rxjs angular2遍歷無限循環的數組

我想創建一個循環遍歷數組中的元素，並且我希望在循環完成後再次運行循環。我已經開始用下面的代碼片段 Observable.interval(1000).startWith(0) .repeat() .take(array.length) .map(i => array[i]) .subscribe(item =

0熱度

2回答

Observable與Angular 4中的setTimeout相結合

有人知道是否可以使用Observable在http請求上設置超時，請參閱我的代碼，我的意圖是：只要我的數據在我的web中更改API（或後端服務器）我想在視圖中刷新我的數據，然後用戶可以知道正在發生的新事情......希望我已經清楚了......如果您不明白，請詢問...或另一種可能性是：每分鐘的功能可以對服務器的新的呼叫，以檢查是否有一些變化.. export interface User {

0熱度

1回答

鏈接接收間隔和延遲

我最近開始學習RxJS。我正在嘗試一下，發現了以下問題。當鏈接在一起的延遲和時間間隔我會假設每個值將在（間隔+延遲）之後發射，但在這裏不是這種情況。更令我感到奇怪的是，當這兩個funcs鏈接在一起時，一些值會同時打印出來，不會有任何延遲。我應該怎麼理解它？我錯過了什麼？我使用RxJS 5.0.3和我在jsbin工作：https://jsbin.com/xoyuded/edit?js,conso

1熱度

2回答

包裹Rx JS通過鏈接可觀察

有沒有辦法通過鏈接將可觀察映射到另一個？我目前這樣做： const myObserverable = fnThatReturnsObserverable(); return anotherFunctionThatReturnsObserverable(myObserverable); 有沒有辦法以鏈接的方式做到這一點？它here return fnThatReturnsObserverabl

1熱度

2回答

可觀察 - 開始發出有條件

有沒有開始從可觀察到的發光有條件值的方法？在我的情況下，.asObservable()函數的用戶只能在CurrentUser初始化後獲得第一個值。 export class CurrentUser { private currentUser$: Observable<CurrentUser>; private currentUserBehaviorSubject: Behav

0熱度

1回答

此關鍵字的功能參數

最近，當我用Rxjs 5，我下載Rxjs使用NPM安裝[email protected]，從下node_modules下載的代碼，我發現Observable.d.ts在Rxjs文件夾中，我看到了它的聲明構造象下面這樣： * * @constructor * @param {Function} subscribe the function that is called when the Obse

1熱度

2回答

rxjs - 什麼是從結果的角度的差異做。做（））的行動和.subscribe（

爲例子，我有以下的代碼，我可以用兩種方式寫： 1. ObsevableA.do(() => { doSomething(); }) .subscribe(); 2. ObservableA.subscribe(() => { doSomething(); }); 結束結果似乎是一樣的。對每種方法有任何想法？我應該使用的最佳做法是什麼？謝謝。