observable

    1熱度

    2回答

    我開發了一個Ionic 3應用程序,它可以根據需要緩存文章內容列表。我正在使用Storage,它使用承諾進行操作。 我的代碼如下: 物品service.ts getArticleFullData(articleId: number) { let appSettings = this.appSettingsService.getSettings(); let params = t

    0熱度

    1回答

    我有一個Observable Obs1已使用從對象數組開始的方法from創建。 我們假設數組有10個對象,這意味着Obs1會發射10次然後終止。 對於由發出的每個對象Obs1我想執行一個返回Observable的函數。因此,相同數量的數組的元素由函數返回的觀測量,我們姑且稱之爲Obs2-1Obs2-2 ... Obs2-10。這些觀測值只發出1個值,然後完成。 我想以某種OBS1鏈接到一系列的觀測

    0熱度

    1回答

    我實施數據存儲服務來分享多個兄弟組件之間的數據。每個組件都需要得到有關數據存儲區更改的通知。數據存儲不會自行填充,數據需要從控制器設置。 data.store.ts @Injectable() export class DocumentIssueStore { private _documentIssue: BehaviorSubject<DocumentIssueModel>;

    1熱度

    3回答

    您好我對Angular和Observables來說很新穎 我想通過循環的方式獲取對象的ID。 但沒有收到我的訂單響應。 例 get ID(1) get ID(2) get ID(3) Receive Object ID(2) Receive Object ID(3) Receive Object ID(1) 是否有可能讓我回來的對象,以便? 下面是我多次調用我的服務功能: confe

    -1熱度

    2回答

    爲什麼Observer界面有Observable?作爲參數? 你是否推薦使用Javas現有類(實現Observer;擴展Observable)? public class Test implements Observer { void update(Observable o, Object arg); }

    1熱度

    1回答

    我目前正在努力弄清楚Angular 4應用程序中Rxjs的行爲。 我的代碼是: this.server.get("incidents") //http get resource .flatMap((res) => res.value) //the incident array is in a property called value of the json returned .map((in

    1熱度

    1回答

    我正在使用JWT刷新令牌策略作爲身份驗證,並且在我的Angular客戶端中有一個攔截器將令牌作爲標頭髮送。 我在發送之前檢查過期時間,並在需要時使用我的refreshToken刷新令牌。 問題是發送2個(或更多)請求時,都嘗試刷新令牌。我需要一個函數,它發送刷新令牌的req,並且一次調用多次,只向服務器發送1個http req以進行刷新,並將新的更新的令牌返回給所有調用它的人。 這是我的攔截器:

    4熱度

    2回答

    我正在用Angular 4和websocket創建聊天應用程序。對於這一點,我已經按照這個Angular websocket tutorial 這裏是WebsocketService源代碼: import { Injectable } from '@angular/core'; import * as Rx from 'rxjs/Rx'; @Injectable() export clas

    4熱度

    1回答

    警告:RxJS newb在這裏。 這裏是我的挑戰: 當onUnlink$觀察到發射... 立即開始從onAdd$觀察到的捕獲值,最多1秒(我會打電話給此分區onAddBuffer$) 。 查詢數據庫(創建doc$觀察到的)來獲取我們將使用來匹配的onAdd$值之一 如果從onAddBuffer$觀察到的一個值的doc$值相匹配的模式,不排放 如果沒有值從onAddBuffer$觀察到的doc$值匹

    1熱度

    1回答

    爲了教育目的,我需要模擬Angular 2中服務器的長響應。我有代碼 getTasks() : Observable<Task[]> { return this.http.get('data/tasks.json').map(response => { return response.json(); }); } // using getTasks().sub