observable

0熱度

1回答

我有一個關於觀察到的問題。例如，我們的API，併發送reguest有： this.http.get('https://swapi.co/api/people/').subscribe(peoplesData => { let peoples = peoplesData.json(); let nextPage = peoples.next; // https://swapi.

0熱度

1回答

返回Observable <number>從另一個可觀測值與一個可觀測的計算<[]>

我想從一個數組上的另一個observable返回一個Observable。我使用該數組查找兩個值並進行計算。目前我正在使用一個很好的承諾，但爲了我自己的理解，我想知道它是如何完成的。如何轉換下面的代碼返回一個無極 convertToCurrency(fromCurrency: string, toCurrency: string) { return new Promise((res

0熱度

1回答

Angular4 - 如何測試一個服務

我對Angular4相當陌生，需要爲我構建的簡單服務編寫單元測試，但不知道從哪裏開始。 import { Injectable } from '@angular/core'; import { Observable } from 'rxjs/Observable'; import { HttpClient } from '@angular/common/http'; import 'rxjs

1熱度

3回答

tslint錯誤盯梢的名字：「可觀測」

運行，我沒有得到之前當tslint我收到以下錯誤.. ERROR: C:/...path..to../observable-debug-operator.ts[27, 13]: Shadowed name: 'Observable' 我跟着這個tutorial添加一個調試操作人員可觀察到的，這是工作正常，除非我得到這個皮棉錯誤。我一直使用這個調試運算符一段時間沒有得到lint錯誤，我不知道爲什

0熱度

2回答

Java可觀察到拋出錯誤，如果它發生

有沒有辦法讓一個Observable只拋出一個例外發生在像flatMap()功能？在Java中，在一個正常的功能，你可以指定它可能會拋出異常： public void dangerousFunction() throws IOException {} 在像flatMap()一個Observable功能，我似乎無法找到類似的語法。我可以用一個try/catch這樣的： myObservable

0熱度

1回答

Rx斯卡拉 - 如何實現排放之間的最短時間

有人可以幫助我想出一個函數，我可以將其應用於可以防止排放快速發生的可觀察項。 val later = Subject[Int]() val combined = Observable.from(List(1,2,3,4,5,6,7,8)) ++ later combined.delayMinTime(1 second).doOnEach(...) 通常情況下，這會發出1-8，然後'隨後'任

1熱度

1回答

使用rxjs預訂毀滅金字塔.subscribe with Angular - 壓扁.subscribees的數量

我目前正在調查RxJS's .merge但是我還會問這裏的問題，因爲我在這裏找到的解釋有時很棒。好的，我有一個表單，根據用戶輸入打開一個模式窗口，我訂閱模式關閉事件並傳回一些數據，我會在調用/訂閱服務方法以檢索一些數據後使用，那麼當發生這種情況時，我再次做同樣的事情，然後調用/訂閱另一個服務方法來更新某個日期，然後在完成後運行本地方法。所以，我在這裏是3套.subscribe小號 const d

-1熱度

1回答

角4分重複點擊GET HTTP觀察數據多次

我有這樣的服務，這爲我提供了數據從API爲可觀察到的。在我的組件中，如果用戶雙擊get方法，數據將被多次推入到數組中。我對RxJs庫很新，但我有一種感覺，可以用.switchMap（）修復，使用BehaviorSubject或者使用|異步管道？「hitsArray」 - 數組，包含HTML中的數據作爲ngFor - 來自http get的responsedata，如果用戶通過「spam」函數將

-1熱度

1回答

只運行observables一次，然後檢查是否完成後 - angular2打字稿

非常新Observables所以道歉，如果這是基本的，但我已經嘗試了谷歌搜索，並且似乎無法找到我想要的。這是一個示例plunkr，非常基本。 https://plnkr.co/edit/kgECPQyoKqY7RamebUUu?p=preview 爲什麼我的Initialized方法在我的服務調用它之前不會調用？我認爲initialized觀測值將盡快執行Observable.forkJoin

1熱度

1回答

敲除：更改可觀察值

我使用requirejs/crossroads設置。這是我的引導與一些全局屬性： ko.applyBindings({ route: router.currentRoute, user: { ... }, ... loading: ko.observable(false), setLoadingState: function