rxjs5

0熱度

1回答

Angular 4中的Observable調用可以像jquery的sync ajax方式嗎？

我有一些業務邏輯函數來調用，其中有一個邏輯，必須使用HttpGet，我必須等到它返回結果contiune，如果我使用jquery的ajax可以簡單地做到這一切，不知道是否Observable也有類似的方法？我希望resut是：約翰安迪但現在的結果是隻顯示安迪 :( function main(){ /* I have more than 70 sharing rules

0熱度

1回答

RxJS遞增驗證事件流

我有一個帶有字符串鍵和值的state對象。事件進入，包含鍵值對來更改state。我需要抖流說：驗證事件，並丟棄所有的修改中去抖週期，如果他們導致無效狀態的差異輸出到最後一個有效的狀態例如，初始狀態爲{k1: "v1"}，事件爲{k2: "v2"}，輸出{k2: "v2"}。但是對於事件：{k3: "v3"}和{k4: "invalid"}，請放棄這兩個更改。所以當一個新事件{k5: "v

1熱度

2回答

RxJS序列更好的方法

我該如何簡化這個序列，因爲我似乎正在重新創造厄運金字塔，並且應該有更多的Rx-y方式。 public isEligibleForOffers(): Observable<Boolean> { return Observable.create((observer) => { this.getAccounts().subscribe( (accounts) => {

-1熱度

2回答

我們可以使用角度爲4的節點js計時器對象嗎？

在我的角度應用程序中，只要頁面處於活動狀態並在屏幕上顯示響應，我需要定期（例如，每y分鐘）進行http調用。這是好使用節點JS計時器對象來實現的setTimeout（）或使用Observable.timer（）。

2熱度

3回答

Rx.js無法獲得值

我想要獲得最後3個值，發佈代碼後，我期待在填充uiOrder和調用cancelOrderItem（）幾次之後，我可以訪問最後3個修訂版本的命令與getHistory（），但我實際上獲得最後（當前）值3倍，我已經嘗試replaySubject（3）具有相同的結果。這是我的代碼： export class OrdersService { public readonly orders: O

0熱度

1回答

提供的參數從可觀察到返回一個可觀察

我有以下簽名功能的功能： fetchUserCar(userId: string): Observable<Car> 但要獲得userId參數，我要調用一個函數，我不能編輯，這是以下內容： private user$ = new ReplaySubject <User>(); public getUser(): Observable <User> { return this.u

1熱度

2回答

RxJS Observable：當對象的特定部分發生變化時發出

我有一個擁有子對象和數組等的複雜對象。我可以很容易地從這個對象創建一個Subject/BehaviourSubject或Observable，這樣我就可以「向下」（發出）新的狀態給訂閱者。 [例如：let appEnv$ = new Rx.BehaviorSubject<IWebSocketAppEnv>(appEnv);] 不過，我不希望我的所有用戶將每次通知的對象更改。例如，對於我的一位訂閱

0熱度

2回答

Forkjoin帶有空的（或沒有）可觀測數組

我試圖檢測所有的可觀察物何時完成。我有以下Observable： let observables:any[] = []; if(valid){ observables.push(new Observable((observer:any) => { async(()=>{ observer.next(); observer.complete();

0熱度

2回答

Observable：驗證來自模擬課程的虛擬數據沒有http

我正在學習Observables並嘗試實施登錄驗證服務。僞數據這樣 export class Users { public users: IUser[] = []; constructor() { this.users = [ new IUser({ username: "protagonist", password: "hello123" }),

2熱度

2回答

Observable.forkJoin更新到TypeScript 2.4.1和Rxjs後的TS2322錯誤5.4.2

在我們的角度4.2.4應用程序中，我們在許多地方使用RxJS的Observable.forkJoin來返回異構類型。例如： private fleet: Aircraft[]; private contractList: string[]; Observable.forkJoin([ this.fleetService.getFleet(), this.fleetSer